private Histogram getHistogramByProbing ( TableCountProbingContext probingContext , int count , long startEpoch , long endEpoch ) { Histogram histogram = new Histogram ( ) ; Map < String , String > values = new HashMap <> ( ) ; values . put ( "table" , probingContext . entity ) ; values . put ( "column" , probingContext . watermarkColumn ) ; values . put ( "greater" , ">=" ) ; values . put ( "less" , "<" ) ; StrSubstitutor sub = new StrSubstitutor ( values ) ; getHistogramRecursively ( probingContext , histogram , sub , values , count , startEpoch , endEpoch ) ; return histogram ; }
Get a histogram for the time range by probing to break down large buckets . Use count instead of querying if it is non - negative .