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 f53bdf8ce8 Make a system property to call system.exit() for
LaunchDataIngestionJobCommand (#10155)
add a519b4f8ac [refactor] combine operator API changes (#10006)
No new revisions were added by this update.
Summary of changes:
.../core/operator/InstanceResponseOperator.java | 14 +-
.../combine/AggregationCombineOperator.java | 21 +--
.../core/operator/combine/BaseCombineOperator.java | 184 ++++-----------------
.../combine/BaseSingleBlockCombineOperator.java | 171 +++++++++++++++++++
.../operator/combine/DistinctCombineOperator.java | 36 +---
.../operator/combine/GroupByCombineOperator.java | 15 +-
...xValueBasedSelectionOrderByCombineOperator.java | 14 +-
.../combine/SelectionOnlyCombineOperator.java | 41 +----
.../combine/SelectionOrderByCombineOperator.java | 47 +-----
.../AggregationResultsBlockMerger.java} | 21 +--
.../DistinctResultsBlockMerger.java} | 27 +--
.../combine/merger/ResultsBlockMerger.java | 57 +++++++
.../SelectionOnlyResultsBlockMerger.java} | 47 +-----
.../SelectionOrderByResultsBlockMerger.java} | 33 +---
.../streaming/BaseStreamingCombineOperator.java | 173 +++++++++++++++++++
.../StreamingAggregationCombineOperator.java} | 26 +--
.../StreamingDistinctCombineOperator.java} | 50 ++----
.../StreamingGroupByCombineOperator.java} | 94 +++++++----
.../StreamingInstanceResponseOperator.java | 50 +++++-
.../StreamingSelectionOnlyCombineOperator.java | 100 +----------
.../streaming/StreamingSelectionOnlyOperator.java | 7 +-
.../StreamingSelectionOrderByCombineOperator.java} | 49 ++----
.../apache/pinot/core/plan/CombinePlanNode.java | 71 +++++---
.../core/plan/maker/InstancePlanMakerImplV2.java | 14 +-
.../startree/operator/StarTreeFilterOperator.java | 2 +-
.../tests/OfflineGRPCServerIntegrationTest.java | 58 +++++--
.../java/org/apache/pinot/spi/utils/LoopUtils.java | 2 +-
27 files changed, 752 insertions(+), 672 deletions(-)
create mode 100644
pinot-core/src/main/java/org/apache/pinot/core/operator/combine/BaseSingleBlockCombineOperator.java
copy
pinot-core/src/main/java/org/apache/pinot/core/operator/combine/{AggregationCombineOperator.java
=> merger/AggregationResultsBlockMerger.java} (69%)
copy
pinot-core/src/main/java/org/apache/pinot/core/operator/combine/{DistinctCombineOperator.java
=> merger/DistinctResultsBlockMerger.java} (71%)
create mode 100644
pinot-core/src/main/java/org/apache/pinot/core/operator/combine/merger/ResultsBlockMerger.java
copy
pinot-core/src/main/java/org/apache/pinot/core/operator/combine/{SelectionOnlyCombineOperator.java
=> merger/SelectionOnlyResultsBlockMerger.java} (57%)
copy
pinot-core/src/main/java/org/apache/pinot/core/operator/combine/{SelectionOrderByCombineOperator.java
=> merger/SelectionOrderByResultsBlockMerger.java} (67%)
create mode 100644
pinot-core/src/main/java/org/apache/pinot/core/operator/streaming/BaseStreamingCombineOperator.java
copy
pinot-core/src/main/java/org/apache/pinot/core/operator/{combine/AggregationCombineOperator.java
=> streaming/StreamingAggregationCombineOperator.java} (53%)
copy
pinot-core/src/main/java/org/apache/pinot/core/operator/{filter/MatchAllFilterOperator.java
=> streaming/StreamingDistinctCombineOperator.java} (50%)
copy
pinot-core/src/main/java/org/apache/pinot/core/operator/{combine/GroupByCombineOperator.java
=> streaming/StreamingGroupByCombineOperator.java} (79%)
copy
pinot-core/src/main/java/org/apache/pinot/core/operator/{filter/MatchAllFilterOperator.java
=> streaming/StreamingSelectionOrderByCombineOperator.java} (50%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
