Druid is an extremely popular tool to perform OLAP queries on event data. Druid drives real-time dashboards in most of the organisations right now. We@Zapr love Druid! Therefore we want to contribute towards making Druid, even more, friendlier to the ever expanding community.
We want to make the process of deep meaningful conversations with Druid little easier. What do we mean is that we don’t want developers to write big, scary JSON anymore but instead use a simple Java-based query generator to help with the querying.
Creating JSON freely can cause tedious bugs such as date type mistakes or spelling mistakes and potentially code can get bigger and messier and less readable. So, in reality, we want to keep the main focus of querying to be the use-case, not the type-checks.
We are excited to know whether you liked it or loved it, so please reach out to us at [email protected]
Druidry is an open-source Java based utility library which supports creating query to Druid automatically taking care of following,
- Type checking.
- Spelling Checks.
- Code reviewability and readability.
This library is still growing and does not support each and every constructs, however it supports the most common one used internally @Zapr.
- Maven
- Java 8
Add this in your pom.xml (assuming maven based project)
<dependency>
<groupId>in.zapr.druid</groupId>
<artifactId>druidry</artifactId>
<version>${LATEST_VERSION}</version>
</dependency>Replace ${LATEST_VERSION} with latest release version
Taking from Druid's example query
{
"queryType": "topN",
"dataSource": "sample_data",
"dimension": "sample_dim",
"threshold": 5,
"metric": "count",
"granularity": "all",
"filter": {
"type": "and",
"fields": [
{
"type": "selector",
"dimension": "dim1",
"value": "some_value"
},
{
"type": "selector",
"dimension": "dim2",
"value": "some_other_val"
}
]
},
"aggregations": [
{
"type": "longSum",
"name": "count",
"fieldName": "count"
},
{
"type": "doubleSum",
"name": "some_metric",
"fieldName": "some_metric"
}
],
"postAggregations": [
{
"type": "arithmetic",
"name": "sample_divide",
"fn": "/",
"fields": [
{
"type": "fieldAccess",
"name": "some_metric",
"fieldName": "some_metric"
},
{
"type": "fieldAccess",
"name": "count",
"fieldName": "count"
}
]
}
],
"intervals": [
"2013-08-31T00:00:00.000/2013-09-03T00:00:00.000"
]
}SelectorFilter selectorFilter1 = new SelectorFilter("dim1", "some_value");
SelectorFilter selectorFilter2 = new SelectorFilter("dim2", "some_other_val");
AndFilter filter = new AndFilter(Arrays.asList(selectorFilter1, selectorFilter2));
DruidAggregator aggregator1 = new LongSumAggregator("count", "count");
DruidAggregator aggregator2 = new DoubleSumAggregator("some_metric", "some_metric");
FieldAccessPostAggregator fieldAccessPostAggregator1
= new FieldAccessPostAggregator("some_metric", "some_metric");
FieldAccessPostAggregator fieldAccessPostAggregator2
= new FieldAccessPostAggregator("count", "count");
DruidPostAggregator postAggregator = ArithmeticPostAggregator.builder()
.name("sample_divide")
.function(ArithmeticFunction.DIVIDE)
.fields(Arrays.asList(fieldAccessPostAggregator1, fieldAccessPostAggregator2))
.build();
DateTime startTime = new DateTime(2013, 8, 31, 0, 0, 0, DateTimeZone.UTC);
DateTime endTime = new DateTime(2013, 9, 3, 0, 0, 0, DateTimeZone.UTC);
Interval interval = new Interval(startTime, endTime);
Granularity granularity = new SimpleGranularity(PredefinedGranularity.ALL);
DruidDimension dimension = new SimpleDimension("sample_dim");
TopNMetric metric = new SimpleMetric("count");
DruidTopNQuery query = DruidTopNQuery.builder()
.dataSource("sample_data")
.dimension(dimension)
.threshold(5)
.topNMetric(metric)
.granularity(granularity)
.filter(filter)
.aggregators(Arrays.asList(aggregator1, aggregator2))
.postAggregators(Collections.singletonList(postAggregator))
.intervals(Collections.singletonList(interval))
.build();
ObjectMapper mapper = new ObjectMapper();
String requiredJson = mapper.writeValueAsString(query);DruidConfiguration config = DruidConfiguration
.builder()
.host("druid.io")
.endpoint("druid/v2/")
.build();
DruidClient client = new DruidJerseyClient(druidConfiguration);
client.connect();
List<DruidResponse> responses = client.query(query, DruidResponse.class);
client.close();- Aggregation Queries
- TopN
- TimeSeries
- GroupBy
- DruidScanQuery
- DruidSelectQuery
- Cardinality
- Count
- DoubleMax
- DoubleMin
- DoubleSum
- DoubleLast
- DoubleFirst
- FloatFirst
- FloatLast
- Filtered
- HyperUnique
- Javascript
- LongMax
- LongMin
- LongSum
- LongFirst
- LongLast
- DistinctCount
- Histogram
- Data Sketches
- ThetaSketch
- TupleSketch
- QuantilesSketch
- HllSketchBuild
- HllSketchMerge
- And
- Bound
- In
- Interval (Without Extraction Function)
- Javascript
- Not
- Or
- Regex
- Search (Without Extraction Function)
- Selector
- Arithmetic
- Constant
- FieldAccess
- HyperUniqueCardinality
- Javascript
- Data Sketches
- Theta Sketch
- ThetaSketchEstimate
- ThetaSketchSetOp
- Tuple Sketch
- TupleSketchToEstimate
- TupleSketchToEstimateAndBounds
- TupleSketchToNumEntries
- TupleSketchToMeans
- TupleSketchToVariances
- TupleSketchToQuantilesSketch
- TupleSketchSetOp
- TupleSketchTTest
- TupleSketchToString
- Quantiles Sketch
- QuantilesSketchToQuantile
- QuantilesSketchToQuantiles
- QuantilesSketchToHistogram
- QuantilesSketchToString
- HLL Sketch
- HllSketchEstimateWithBounds
- HllSketchUnion
- HllSketchToString
- Theta Sketch
- Expression
- Duration
- Period
- Predefined
For any features or bugs, please raise it in issues section
If anything else, get in touch with us at [email protected]
![dependabot[bot] avatar](https://avatars.githubusercontent.com/in/29110?v=4 "dependabot[bot]")
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent