You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pinot.apache.org by xi...@apache.org on 2023/05/04 23:56:25 UTC
[pinot] branch master updated (b190599cf1 -> 815cd6ebb7)
This is an automated email from the ASF dual-hosted git repository.
xiangfu pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
from b190599cf1 [cleanup] last place to clean up OpChain wake up callback (#10710)
add 815cd6ebb7 [multistage]Refactor Mailbox assignment logic to planner (#10708)
No new revisions were added by this update.
Summary of changes:
pinot-common/src/main/proto/worker.proto | 11 ++-
.../org/apache/pinot/query/planner/QueryPlan.java | 10 ++-
.../planner/physical/DispatchablePlanMetadata.java | 23 ++++-
.../planner/physical/DispatchablePlanVisitor.java | 11 ++-
.../planner/physical/MailboxAssignmentVisitor.java | 90 ++++++++++++++++++++
.../query/planner/physical/MailboxIdUtils.java | 37 +++-----
.../pinot/query/routing/MailboxMetadata.java | 98 ++++++++++++++++++++++
.../apache/pinot/query/routing/WorkerMetadata.java | 23 ++++-
.../apache/pinot/query/mailbox/MailboxIdUtils.java | 11 +++
.../apache/pinot/query/mailbox/MailboxService.java | 2 +
.../apache/pinot/query/runtime/QueryRunner.java | 6 +-
.../operator/BaseMailboxReceiveOperator.java | 42 ++++------
.../runtime/operator/MailboxSendOperator.java | 49 ++++-------
.../query/runtime/plan/DistributedStagePlan.java | 19 ++---
.../runtime/plan/OpChainExecutionContext.java | 13 ++-
.../query/runtime/plan/PlanRequestContext.java | 10 +--
.../runtime/plan/ServerRequestPlanVisitor.java | 2 +-
.../runtime/plan/serde/QueryPlanSerDeUtils.java | 59 +++++++++----
.../plan/server/ServerPlanRequestContext.java | 5 +-
.../query/service/dispatch/QueryDispatcher.java | 7 +-
.../operator/MailboxReceiveOperatorTest.java | 72 ++++++++++------
.../runtime/operator/MailboxSendOperatorTest.java | 2 +-
.../pinot/query/runtime/operator/OpChainTest.java | 31 +++++--
.../query/runtime/operator/OperatorTestUtil.java | 7 +-
.../operator/SortedMailboxReceiveOperatorTest.java | 74 ++++++++++------
.../pinot/query/service/QueryServerTest.java | 11 +--
26 files changed, 514 insertions(+), 211 deletions(-)
create mode 100644 pinot-query-planner/src/main/java/org/apache/pinot/query/planner/physical/MailboxAssignmentVisitor.java
copy pinot-minion/src/main/java/org/apache/pinot/minion/event/MinionTaskState.java => pinot-query-planner/src/main/java/org/apache/pinot/query/planner/physical/MailboxIdUtils.java (67%)
create mode 100644 pinot-query-planner/src/main/java/org/apache/pinot/query/routing/MailboxMetadata.java
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org