You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pinot.apache.org by ro...@apache.org on 2022/11/14 22:54:06 UTC
[pinot] branch master updated (7b98e30441 -> 78504b9413)
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 7b98e30441 [multistage] expand test framework features (#9794)
add 78504b9413 [multistage] refactor MailboxSendOperator for testability and tests (#9773)
No new revisions were added by this update.
Summary of changes:
.../apache/pinot/query/runtime/QueryRunner.java | 2 +-
.../pinot/query/runtime/blocks/BlockSplitter.java | 20 +--
.../runtime/blocks/TransferableBlockUtils.java | 11 +-
.../runtime/operator/MailboxSendOperator.java | 193 ++++++---------------
.../runtime/operator/exchange/BlockExchange.java | 114 ++++++++++++
.../operator/exchange/BroadcastExchange.java | 35 ++--
.../runtime/operator/exchange/HashExchange.java | 65 +++++++
.../runtime/operator/exchange/RandomExchange.java | 59 +++++++
.../operator/exchange/SingletonExchange.java | 46 +++++
.../query/runtime/plan/PhysicalPlanVisitor.java | 2 +-
.../runtime/blocks/TransferableBlockUtilsTest.java | 13 +-
.../runtime/operator/MailboxSendOperatorTest.java | 166 ++++++++++++++++++
.../operator/exchange/BlockExchangeTest.java | 177 +++++++++++++++++++
.../operator/exchange/BroadcastExchangeTest.java | 79 +++++++++
.../operator/exchange/HashExchangeTest.java | 109 ++++++++++++
.../operator/exchange/RandomExchangeTest.java | 73 ++++++++
.../operator/exchange/SingletonExchangeTest.java | 73 ++++++++
17 files changed, 1056 insertions(+), 181 deletions(-)
copy pinot-core/src/main/java/org/apache/pinot/core/plan/PlanNode.java => pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/blocks/BlockSplitter.java (61%)
create mode 100644 pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/operator/exchange/BlockExchange.java
copy pinot-core/src/main/java/org/apache/pinot/core/data/table/BaseTable.java => pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/operator/exchange/BroadcastExchange.java (52%)
create mode 100644 pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/operator/exchange/HashExchange.java
create mode 100644 pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/operator/exchange/RandomExchange.java
create mode 100644 pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/operator/exchange/SingletonExchange.java
create mode 100644 pinot-query-runtime/src/test/java/org/apache/pinot/query/runtime/operator/MailboxSendOperatorTest.java
create mode 100644 pinot-query-runtime/src/test/java/org/apache/pinot/query/runtime/operator/exchange/BlockExchangeTest.java
create mode 100644 pinot-query-runtime/src/test/java/org/apache/pinot/query/runtime/operator/exchange/BroadcastExchangeTest.java
create mode 100644 pinot-query-runtime/src/test/java/org/apache/pinot/query/runtime/operator/exchange/HashExchangeTest.java
create mode 100644 pinot-query-runtime/src/test/java/org/apache/pinot/query/runtime/operator/exchange/RandomExchangeTest.java
create mode 100644 pinot-query-runtime/src/test/java/org/apache/pinot/query/runtime/operator/exchange/SingletonExchangeTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org