This is an automated email from the ASF dual-hosted git repository.
xiangfu0 pushed a change to branch xiangfu0/codex1/sorted-exchange-core
in repository https://gitbox.apache.org/repos/asf/pinot.git
from 6dff6515d08 [MSE] Use current planner test APIs
add dcf319f474a [build] Include Zstd API annotations for compiler
validation
add 7a4465c289c [MSE] Express ordered streams with a k-way merge exchange
add fde1708cf3d Retain complete input for global window receiver sorts
No new revisions were added by this update.
Summary of changes:
.../broker/broker/helix/BaseBrokerStarter.java | 8 +
.../requesthandler/KWayMergeSupportPredicate.java | 99 ++++++++++
.../MultiStageBrokerRequestHandler.java | 8 +
.../KWayMergeSupportPredicateTest.java | 107 +++++++++++
pinot-common/src/main/proto/plan.proto | 13 ++
.../rel/logical/PinotKWayMergeSortExchange.java | 52 +++++
.../rules/PinotWindowExchangeNodeInsertRule.java | 27 ++-
.../org/apache/pinot/query/QueryEnvironment.java | 6 +
.../query/planner/explain/PlanNodeMerger.java | 12 +-
.../planner/logical/EquivalentStagesFinder.java | 10 +-
.../query/planner/logical/PlanFragmenter.java | 21 +-
.../planner/logical/PlanNodeToRelConverter.java | 14 +-
.../planner/logical/RelToPlanNodeConverter.java | 8 +
.../pinot/query/planner/plannode/ExchangeNode.java | 2 +-
.../planner/plannode/KWayMergeExchangeNode.java | 44 +++++
.../planner/plannode/MailboxMergeReceiveNode.java | 87 +++++++++
.../query/planner/plannode/MailboxReceiveNode.java | 2 +-
.../query/planner/plannode/MailboxSendNode.java | 12 --
.../query/planner/serde/PlanNodeDeserializer.java | 11 ++
.../query/planner/serde/PlanNodeSerializer.java | 12 ++
.../PinotWindowExchangeNodeInsertRuleTest.java | 3 +
.../apache/pinot/query/QueryCompilationTest.java | 40 ++--
.../pinot/query/QueryEnvironmentTestBase.java | 13 +-
.../query/planner/serde/PlanNodeSerDeTest.java | 22 +++
.../pinot/query/mailbox/GrpcSendingMailbox.java | 23 +--
.../query/mailbox/InMemorySendingMailbox.java | 10 +-
.../apache/pinot/query/mailbox/MailboxService.java | 10 +-
.../pinot/query/mailbox/ReceivingMailbox.java | 52 ++---
.../pinot/query/mailbox/channel/ChannelUtils.java | 4 -
.../mailbox/channel/MailboxContentObserver.java | 5 +-
.../runtime/operator/MailboxSendOperator.java | 28 +--
.../SortedMailboxMergeReceiveOperator.java | 155 +++++----------
.../utils/BlockingMultiStreamConsumer.java | 10 -
.../query/runtime/operator/utils/SortUtils.java | 16 --
.../query/runtime/plan/PlanNodeToOpChain.java | 10 +-
.../plan/server/ServerPlanRequestVisitor.java | 16 +-
.../pinot/query/mailbox/MailboxServiceTest.java | 18 +-
.../channel/MailboxContentObserverTest.java | 34 ----
.../runtime/operator/MailboxSendOperatorTest.java | 14 --
.../query/runtime/operator/OperatorTestUtil.java | 4 -
.../SortedMailboxMergeReceiveOperatorTest.java | 214 +++++++--------------
.../operator/WindowAggregateOperatorTest.java | 46 +++++
.../plan/OpChainConverterDispatcherTest.java | 16 +-
.../plan/server/ServerPlanRequestVisitorTest.java | 6 +-
pinot-segment-local/pom.xml | 7 +
.../apache/pinot/spi/utils/CommonConstants.java | 1 +
46 files changed, 809 insertions(+), 523 deletions(-)
create mode 100644
pinot-broker/src/main/java/org/apache/pinot/broker/requesthandler/KWayMergeSupportPredicate.java
create mode 100644
pinot-broker/src/test/java/org/apache/pinot/broker/requesthandler/KWayMergeSupportPredicateTest.java
create mode 100644
pinot-query-planner/src/main/java/org/apache/pinot/calcite/rel/logical/PinotKWayMergeSortExchange.java
create mode 100644
pinot-query-planner/src/main/java/org/apache/pinot/query/planner/plannode/KWayMergeExchangeNode.java
create mode 100644
pinot-query-planner/src/main/java/org/apache/pinot/query/planner/plannode/MailboxMergeReceiveNode.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
