Releasing 3.1

src/main/java/in/zapr/druid/druidry/query/aggregation/DruidTimeSeriesQuery.java

@@ -40,13 +40,14 @@
 public class DruidTimeSeriesQuery extends DruidAggregationQuery {
     // TODO: String or Boolean??
     private Boolean descending;
+    private Integer limit;
 
     @Builder
     private DruidTimeSeriesQuery(@NonNull DataSource dataSource, Boolean descending,
                                  @NonNull List<Interval> intervals, @NonNull Granularity granularity,
                                  List<DruidVirtualColumn> virtualColumns,
                                  DruidFilter filter, List<DruidAggregator> aggregators,
-                                 List<DruidPostAggregator> postAggregators, Context context) {
+                                 List<DruidPostAggregator> postAggregators, Integer limit, Context context) {
 
         this.queryType = QueryType.TIMESERIES;
         this.dataSource = dataSource;
@@ -57,6 +58,7 @@ private DruidTimeSeriesQuery(@NonNull DataSource dataSource, Boolean descending,
         this.filter = filter;
         this.aggregations = aggregators;
         this.postAggregations = postAggregators;
+        this.limit = limit;
         this.context = context;
     }
 }

src/test/java/in/zapr/druid/druidry/query/aggregation/TimeSeriesTest.java

@@ -209,6 +209,7 @@ public void testAllFields() throws JSONException, JsonProcessingException {
                 .filter(filter)
                 .aggregators(Collections.singletonList(aggregator))
                 .postAggregators(Collections.singletonList(postAggregator))
+                .limit(5)
                 .context(context)
                 .build();
 
@@ -239,6 +240,7 @@ public void testAllFields() throws JSONException, JsonProcessingException {
         expectedQuery.put("intervals", new JSONArray(Collections
                 .singletonList("2013-07-14T00:00:00.000Z/2013-11-16T00:00:00.000Z")));
         expectedQuery.put("granularity", "day");
+        expectedQuery.put("limit", 5);
         expectedQuery.put("aggregations", new JSONArray(Collections.singletonList(expectedAggregator)));
         expectedQuery.put("postAggregations", new JSONArray(Collections.singletonList(expectedPostAggregator)));
         expectedQuery.put("filter", expectedFilter);