This module provides Druid aggregators based on numeric quantiles DoublesSketch from datasketches library. Quantiles sketch is a mergeable streaming algorithm to estimate the distribution of values, and approximately answer queries about the rank of a value, probability mass function of the distribution (PMF) or histogram, cummulative distribution function (CDF), and quantiles (median, min, max, 95th percentile and such). See Quantiles Sketch Overview.
There are three major modes of operation:
To use this aggregator, make sure you include the extension in your config file:
druid.extensions.loadList=["druid-datasketches"]
The result of the aggregation is a DoublesSketch that is the union of all sketches either built from raw data or read from the segments.
{ "type" : "quantilesDoublesSketch", "name" : <output_name>, "fieldName" : <metric_name>, "k": <parameter that controls size and accuracy> }
| property | description | required? |
|---|---|---|
| type | This String should always be “quantilesDoublesSketch” | yes |
| name | A String for the output (result) name of the calculation. | yes |
| fieldName | A String for the name of the input field (can contain sketches or raw numeric values). | yes |
| k | Parameter that determines the accuracy and size of the sketch. Higher k means higher accuracy but more space to store sketches. Must be a power of 2 from 2 to 32768. See the Quantiles Accuracy for details. | no, defaults to 128 |
This returns an approximation to the value that would be preceded by a given fraction of a hypothetical sorted version of the input stream.
{ "type" : "quantilesDoublesSketchToQuantile", "name": <output name>, "field" : <post aggregator that refers to a DoublesSketch (fieldAccess or another post aggregator)>, "fraction" : <fractional position in the hypothetical sorted stream, number from 0 to 1 inclusive> }
This returns an array of quantiles corresponding to a given array of fractions
{ "type" : "quantilesDoublesSketchToQuantiles", "name": <output name>, "field" : <post aggregator that refers to a DoublesSketch (fieldAccess or another post aggregator)>, "fractions" : <array of fractional positions in the hypothetical sorted stream, number from 0 to 1 inclusive> }
This returns an approximation to the histogram given an array of split points that define the histogram bins. An array of m unique, monotonically increasing split points divide the real number line into m+1 consecutive disjoint intervals. The definition of an interval is inclusive of the left split point and exclusive of the right split point.
{ "type" : "quantilesDoublesSketchToHistogram", "name": <output name>, "field" : <post aggregator that refers to a DoublesSketch (fieldAccess or another post aggregator)>, "splitPoints" : <array of split points> }
This returns a summary of the sketch that can be used for debugging. This is the result of calling toString() method.
{ "type" : "quantilesDoublesSketchToString", "name": <output name>, "field" : <post aggregator that refers to a DoublesSketch (fieldAccess or another post aggregator)> }