File tree Expand file tree Collapse file tree 2 files changed +14
-0
lines changed
pinot-core/src/main/java/org/apache/pinot/core/query/reduce Expand file tree Collapse file tree 2 files changed +14
-0
lines changed Original file line number Diff line number Diff line change 3030
3131/**
3232 * Helper class to reduce and set gap fill results into the BrokerResponseNative
33+ *
34+ * {@link CountGapfillProcessor} is only applying the count aggregation function on the gapfilled result for each time
35+ * bucket.
36+ *
37+ * {@link CountGapfillProcessor} is different from {@link GapfillProcessor} that {@link GapfillProcessor} will create
38+ * the gapfilled entries, but {@link CountGapfillProcessor} does not generate the gapfilled entries. It just updated
39+ * the aggregated count as necessary.
3340 */
3441class CountGapfillProcessor extends BaseGapfillProcessor {
3542 protected final Set <Key > _filteredSet ;
Original file line number Diff line number Diff line change 3030
3131/**
3232 * Helper class to reduce and set gap fill results into the BrokerResponseNative
33+ *
34+ * {@link SumAvgGapfillProcessor} is only applying the sum and/or avg aggregation function on the gapfilled result for
35+ * each time bucket.
36+ *
37+ * {@link SumAvgGapfillProcessor} is different from {@link GapfillProcessor} that {@link GapfillProcessor} will create
38+ * the gapfilled entries, but {@link SumAvgGapfillProcessor} does not generate the gapfilled entries. It just updated
39+ * the aggregated sum and/or avg counters as necessary.
3340 */
3441class SumAvgGapfillProcessor extends BaseGapfillProcessor {
3542 private final double [] _sumes ;
You can’t perform that action at this time.
0 commit comments