This is an automated email from the ASF dual-hosted git repository.
gortiz pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
from 4588f8ca34 Config for max output segment size in UpsertCompactMerge
task (#14742)
add 3adcedb80c [Spool] Actual implementation (#14507)
No new revisions were added by this update.
Summary of changes:
.../MultiStageBrokerRequestHandler.java | 3 +
pinot-common/src/main/proto/plan.proto | 4 +-
.../org/apache/pinot/query/QueryEnvironment.java | 48 +++---
.../apache/pinot/query/context/PlannerContext.java | 9 +-
.../explain/PhysicalExplainPlanVisitor.java | 25 ++-
.../planner/logical/EquivalentStagesFinder.java | 2 +-
.../planner/logical/EquivalentStagesReplacer.java | 20 ++-
.../planner/logical/PinotLogicalQueryPlanner.java | 12 +-
.../query/planner/logical/PlanFragmenter.java | 13 +-
.../planner/physical/DispatchablePlanVisitor.java | 18 ++-
.../planner/physical/MailboxAssignmentVisitor.java | 171 +++++++++++----------
.../planner/physical/PinotDispatchPlanner.java | 2 +-
.../colocated/GreedyShuffleRewriteVisitor.java | 29 +++-
.../query/planner/plannode/MailboxSendNode.java | 15 ++
.../query/planner/serde/PlanNodeDeserializer.java | 12 +-
.../query/planner/serde/PlanNodeSerializer.java | 12 +-
.../resources/queries/ExplainPhysicalPlans.json | 92 +++++++++++
.../pinot/query/mailbox/GrpcSendingMailbox.java | 10 +-
.../query/mailbox/InMemorySendingMailbox.java | 5 +
.../apache/pinot/query/runtime/QueryRunner.java | 16 +-
.../pinot/query/runtime/blocks/BlockSplitter.java | 2 +
.../query/runtime/operator/HashJoinOperator.java | 10 +-
.../runtime/operator/MailboxSendOperator.java | 54 ++++++-
.../runtime/operator/exchange/BlockExchange.java | 102 +++++++++++-
.../operator/exchange/BroadcastExchange.java | 4 +-
.../runtime/operator/exchange/HashExchange.java | 4 +-
.../runtime/operator/exchange/RandomExchange.java | 4 +-
.../operator/exchange/SingletonExchange.java | 4 +-
.../utils/BlockingMultiStreamConsumer.java | 19 ++-
.../operator/exchange/BlockExchangeTest.java | 4 +-
.../src/test/resources/queries/Spool.json | 37 +++++
.../apache/pinot/spi/utils/CommonConstants.java | 8 +
32 files changed, 596 insertions(+), 174 deletions(-)
create mode 100644 pinot-query-runtime/src/test/resources/queries/Spool.json
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
