This is an automated email from the ASF dual-hosted git repository.
rongr pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
from 948957a29e Support null in InTransformFunction and
NotInTransformFunction. (#10604)
add bcfcd0a4ab [multistage]re-implement mailbox (#10681)
No new revisions were added by this update.
Summary of changes:
.../MultiStageBrokerRequestHandler.java | 23 +-
.../pinot/query/mailbox/GrpcMailboxService.java | 154 ------
.../pinot/query/mailbox/GrpcReceivingMailbox.java | 162 ------
.../pinot/query/mailbox/GrpcSendingMailbox.java | 104 ++--
.../query/mailbox/InMemoryMailboxService.java | 106 ----
.../query/mailbox/InMemoryReceivingMailbox.java | 80 ---
.../query/mailbox/InMemorySendingMailbox.java | 64 +--
.../pinot/query/mailbox/JsonMailboxIdentifier.java | 157 ------
.../apache/pinot/query/mailbox/MailboxIdUtils.java | 32 +-
.../pinot/query/mailbox/MailboxIdentifier.java | 63 ---
.../apache/pinot/query/mailbox/MailboxService.java | 145 ++++--
.../query/mailbox/MultiplexingMailboxService.java | 96 ----
.../pinot/query/mailbox/ReceivingMailbox.java | 127 +++--
.../apache/pinot/query/mailbox/SendingMailbox.java | 28 +-
.../query/mailbox/channel/ChannelManager.java | 15 -
.../pinot/query/mailbox/channel/ChannelUtils.java | 7 +-
.../query/mailbox/channel/GrpcMailboxServer.java | 25 +-
.../mailbox/channel/InMemoryTransferStream.java | 101 ----
.../mailbox/channel/MailboxContentObserver.java | 127 +++++
.../channel/MailboxContentStreamObserver.java | 172 -------
...eamObserver.java => MailboxStatusObserver.java} | 37 +-
.../apache/pinot/query/runtime/QueryRunner.java | 22 +-
.../query/runtime/executor/OpChainScheduler.java | 5 +-
.../runtime/executor/OpChainSchedulerService.java | 12 +-
.../runtime/executor/RoundRobinScheduler.java | 24 +-
.../operator/BaseMailboxReceiveOperator.java | 64 +--
.../runtime/operator/MailboxReceiveOperator.java | 51 +-
.../runtime/operator/MailboxSendOperator.java | 131 ++---
.../pinot/query/runtime/operator/OpChain.java | 15 +-
.../operator/SortedMailboxReceiveOperator.java | 54 +-
.../runtime/operator/exchange/BlockExchange.java | 27 +-
.../operator/exchange/BroadcastExchange.java | 4 +-
.../runtime/operator/exchange/HashExchange.java | 4 +-
.../runtime/operator/exchange/RandomExchange.java | 7 +-
.../operator/exchange/SingletonExchange.java | 4 +-
.../runtime/plan/OpChainExecutionContext.java | 7 +-
.../query/runtime/plan/PhysicalPlanVisitor.java | 12 +-
.../query/runtime/plan/PlanRequestContext.java | 22 +-
.../runtime/plan/ServerRequestPlanVisitor.java | 30 +-
.../plan/server/ServerPlanRequestContext.java | 7 +-
.../query/service/dispatch/QueryDispatcher.java | 23 +-
.../query/mailbox/GrpcMailboxServiceTest.java | 362 -------------
.../query/mailbox/InMemoryMailboxServiceTest.java | 222 --------
.../query/mailbox/JsonMailboxIdentifierTest.java | 51 --
.../pinot/query/mailbox/MailboxServiceTest.java | 567 +++++++++++++++++++++
.../mailbox/MultiplexingMailboxServiceTest.java | 96 ----
.../pinot/query/runtime/QueryRunnerTest.java | 7 +-
.../pinot/query/runtime/QueryRunnerTestBase.java | 8 +-
.../runtime/executor/RoundRobinSchedulerTest.java | 42 +-
.../operator/MailboxReceiveOperatorTest.java | 267 +++-------
.../runtime/operator/MailboxSendOperatorTest.java | 156 +++---
.../pinot/query/runtime/operator/OpChainTest.java | 141 +++--
.../operator/SortedMailboxReceiveOperatorTest.java | 312 ++++--------
.../operator/exchange/BlockExchangeTest.java | 16 +-
.../operator/exchange/BroadcastExchangeTest.java | 9 +-
.../operator/exchange/HashExchangeTest.java | 11 +-
.../operator/exchange/RandomExchangeTest.java | 8 +-
.../operator/exchange/SingletonExchangeTest.java | 6 +-
.../runtime/queries/ResourceBasedQueriesTest.java | 19 +-
59 files changed, 1568 insertions(+), 3082 deletions(-)
delete mode 100644
pinot-query-runtime/src/main/java/org/apache/pinot/query/mailbox/GrpcMailboxService.java
delete mode 100644
pinot-query-runtime/src/main/java/org/apache/pinot/query/mailbox/GrpcReceivingMailbox.java
delete mode 100644
pinot-query-runtime/src/main/java/org/apache/pinot/query/mailbox/InMemoryMailboxService.java
delete mode 100644
pinot-query-runtime/src/main/java/org/apache/pinot/query/mailbox/InMemoryReceivingMailbox.java
delete mode 100644
pinot-query-runtime/src/main/java/org/apache/pinot/query/mailbox/JsonMailboxIdentifier.java
copy pinot-tools/src/main/java/org/apache/pinot/tools/streams/RSVP.java =>
pinot-query-runtime/src/main/java/org/apache/pinot/query/mailbox/MailboxIdUtils.java
(51%)
delete mode 100644
pinot-query-runtime/src/main/java/org/apache/pinot/query/mailbox/MailboxIdentifier.java
delete mode 100644
pinot-query-runtime/src/main/java/org/apache/pinot/query/mailbox/MultiplexingMailboxService.java
delete mode 100644
pinot-query-runtime/src/main/java/org/apache/pinot/query/mailbox/channel/InMemoryTransferStream.java
create mode 100644
pinot-query-runtime/src/main/java/org/apache/pinot/query/mailbox/channel/MailboxContentObserver.java
delete mode 100644
pinot-query-runtime/src/main/java/org/apache/pinot/query/mailbox/channel/MailboxContentStreamObserver.java
rename
pinot-query-runtime/src/main/java/org/apache/pinot/query/mailbox/channel/{MailboxStatusStreamObserver.java
=> MailboxStatusObserver.java} (66%)
delete mode 100644
pinot-query-runtime/src/test/java/org/apache/pinot/query/mailbox/GrpcMailboxServiceTest.java
delete mode 100644
pinot-query-runtime/src/test/java/org/apache/pinot/query/mailbox/InMemoryMailboxServiceTest.java
delete mode 100644
pinot-query-runtime/src/test/java/org/apache/pinot/query/mailbox/JsonMailboxIdentifierTest.java
create mode 100644
pinot-query-runtime/src/test/java/org/apache/pinot/query/mailbox/MailboxServiceTest.java
delete mode 100644
pinot-query-runtime/src/test/java/org/apache/pinot/query/mailbox/MultiplexingMailboxServiceTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@pinot.apache.org
For additional commands, e-mail: commits-h...@pinot.apache.org
