This is an automated email from the ASF dual-hosted git repository.
jackie pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
from f7f054f3506 [Plannner] Support tracing of planner rule productions
(#16581)
add 3349df12a82 [SSE] Trim group when orderBy key is same as groupBy key,
sort-aggregate and pair-wise merge (#16308)
No new revisions were added by this update.
Summary of changes:
.../common/utils/config/QueryOptionsUtils.java | 14 +
.../pinot/core/data/table/SortedRecordTable.java | 185 ++++++++
.../pinot/core/data/table/SortedRecords.java | 12 +-
.../pinot/core/data/table/SortedRecordsMerger.java | 138 ++++++
.../apache/pinot/core/data/table/TableResizer.java | 38 +-
.../blocks/results/GroupByResultsBlock.java | 7 +-
.../SequentialSortedGroupByCombineOperator.java | 219 +++++++++
...ator.java => SortedGroupByCombineOperator.java} | 197 ++++----
.../operator/query/FilteredGroupByOperator.java | 59 ++-
.../pinot/core/operator/query/GroupByOperator.java | 57 ++-
.../apache/pinot/core/plan/CombinePlanNode.java | 9 +
.../groupby/DefaultGroupByExecutor.java | 6 +-
.../query/aggregation/groupby/GroupByExecutor.java | 4 +-
.../core/query/request/context/QueryContext.java | 63 ++-
.../core/query/utils/OrderByComparatorFactory.java | 104 +++++
.../org/apache/pinot/core/util/GroupByUtils.java | 33 +-
.../pinot/core/data/table/TableResizerTest.java | 6 +-
.../combine/SortedGroupByCombineOperatorsTest.java | 505 +++++++++++++++++++++
.../pinot/queries/BaseFunnelCountQueriesTest.java | 15 +-
.../apache/pinot/queries/FastHllQueriesTest.java | 12 +-
.../apache/pinot/queries/HistogramQueriesTest.java | 18 +-
.../pinot/queries/SerializedBytesQueriesTest.java | 42 +-
.../pinot/queries/StatisticalQueriesTest.java | 38 +-
.../tests/GroupByTrimmingIntegrationTest.java | 17 +-
...flineClusterMemBasedServerQueryKillingTest.java | 56 +++
...BenchmarkAggregateGroupByOrderByQueriesSSE.java | 262 ++++++++++-
.../BenchmarkPairwiseCombineOrderByGroupBy.java | 338 ++++++++++++++
.../apache/pinot/spi/utils/CommonConstants.java | 16 +
28 files changed, 2224 insertions(+), 246 deletions(-)
create mode 100644
pinot-core/src/main/java/org/apache/pinot/core/data/table/SortedRecordTable.java
copy
pinot-common/src/main/java/org/apache/pinot/common/exception/SchemaBackwardIncompatibleException.java
=>
pinot-core/src/main/java/org/apache/pinot/core/data/table/SortedRecords.java
(80%)
create mode 100644
pinot-core/src/main/java/org/apache/pinot/core/data/table/SortedRecordsMerger.java
create mode 100644
pinot-core/src/main/java/org/apache/pinot/core/operator/combine/SequentialSortedGroupByCombineOperator.java
copy
pinot-core/src/main/java/org/apache/pinot/core/operator/combine/{GroupByCombineOperator.java
=> SortedGroupByCombineOperator.java} (52%)
create mode 100644
pinot-core/src/test/java/org/apache/pinot/core/operator/combine/SortedGroupByCombineOperatorsTest.java
copy pinot-core/src/test/java/org/apache/pinot/queries/BaseQueriesTest.java =>
pinot-perf/src/main/java/org/apache/pinot/perf/BenchmarkAggregateGroupByOrderByQueriesSSE.java
(60%)
create mode 100644
pinot-perf/src/main/java/org/apache/pinot/perf/BenchmarkPairwiseCombineOrderByGroupBy.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
