diff --git a/processing/src/main/java/org/apache/druid/query/CursorGranularizer.java b/processing/src/main/java/org/apache/druid/query/CursorGranularizer.java index ffdb5bd15fa9..06b9ec56fd86 100644 --- a/processing/src/main/java/org/apache/druid/query/CursorGranularizer.java +++ b/processing/src/main/java/org/apache/druid/query/CursorGranularizer.java @@ -95,12 +95,11 @@ public static CursorGranularizer create( timeSelector = cursor.getColumnSelectorFactory().makeColumnValueSelector(ColumnHolder.TIME_COLUMN_NAME); } - return new CursorGranularizer(cursor, granularity, bucketIterable, timeSelector, timeOrder == Order.DESCENDING); + return new CursorGranularizer(cursor, bucketIterable, timeSelector, timeOrder == Order.DESCENDING); } private final Cursor cursor; - private final Granularity granularity; // Iterable that iterates over time buckets. private final Iterable bucketIterable; @@ -115,14 +114,12 @@ public static CursorGranularizer create( private CursorGranularizer( Cursor cursor, - Granularity granularity, Iterable bucketIterable, @Nullable ColumnValueSelector timeSelector, boolean descending ) { this.cursor = cursor; - this.granularity = granularity; this.bucketIterable = bucketIterable; this.timeSelector = timeSelector; this.descending = descending;