This is an automated email from the ASF dual-hosted git repository.
jackie pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
from c64040b017 add additional lucene index configs (#11354)
add a5a1641e60 Remove noop (#11205)
No new revisions were added by this update.
Summary of changes:
.../MultiStageBrokerRequestHandler.java | 19 +-
.../pinot/common/datablock/DataBlockUtils.java | 4 -
.../pinot/common/datablock/MetadataBlock.java | 14 +-
.../pinot/query/mailbox/GrpcSendingMailbox.java | 10 +-
.../apache/pinot/query/mailbox/MailboxService.java | 5 +
.../pinot/query/mailbox/ReceivingMailbox.java | 35 +++
.../apache/pinot/query/runtime/QueryRunner.java | 47 ++--
.../query/runtime/blocks/TransferableBlock.java | 13 +-
.../runtime/blocks/TransferableBlockUtils.java | 8 -
.../runtime/executor/ExecutorServiceUtils.java | 78 ++++++
.../runtime/executor/OpChainSchedulerService.java | 195 +++++----------
.../runtime/executor/RoundRobinScheduler.java | 263 ---------------------
.../query/runtime/operator/AggregateOperator.java | 52 ++--
.../operator/BaseMailboxReceiveOperator.java | 62 ++++-
.../query/runtime/operator/FilterOperator.java | 2 +-
.../query/runtime/operator/HashJoinOperator.java | 26 +-
.../LeafStageTransferableBlockOperator.java | 3 -
.../runtime/operator/MailboxReceiveOperator.java | 43 +---
.../runtime/operator/MailboxSendOperator.java | 39 ++-
.../pinot/query/runtime/operator/OpChain.java | 28 ++-
.../query/runtime/operator/OperatorStats.java | 8 +-
.../pinot/query/runtime/operator/SetOperator.java | 9 +-
.../pinot/query/runtime/operator/SortOperator.java | 20 +-
.../operator/SortedMailboxReceiveOperator.java | 59 ++---
.../query/runtime/operator/TransformOperator.java | 11 +-
.../runtime/operator/WindowAggregateOperator.java | 30 +--
.../query/runtime/operator/utils/AsyncStream.java | 73 ++++++
.../utils/BlockingMultiStreamConsumer.java | 252 ++++++++++++++++++++
.../runtime/operator/utils/BlockingStream.java | 30 +--
.../query/runtime/plan/PhysicalPlanContext.java | 20 +-
.../plan/pipeline/PipelineBreakerExecutor.java | 23 +-
.../plan/pipeline/PipelineBreakerOperator.java | 73 +++---
.../pinot/query/mailbox/MailboxServiceTest.java | 28 +++
.../pinot/query/runtime/QueryRunnerTest.java | 15 +-
.../pinot/query/runtime/QueryRunnerTestBase.java | 13 +-
.../executor/OpChainSchedulerServiceTest.java | 125 ++--------
.../runtime/executor/RoundRobinSchedulerTest.java | 185 ---------------
.../runtime/operator/AggregateOperatorTest.java | 31 ---
.../query/runtime/operator/FilterOperatorTest.java | 14 --
.../runtime/operator/HashJoinOperatorTest.java | 111 ---------
.../operator/MailboxReceiveOperatorTest.java | 50 ++--
.../runtime/operator/MailboxSendOperatorTest.java | 65 ++---
.../pinot/query/runtime/operator/OpChainTest.java | 9 +-
.../query/runtime/operator/SortOperatorTest.java | 26 +-
.../operator/SortedMailboxReceiveOperatorTest.java | 66 ++----
.../runtime/operator/TransformOperatorTest.java | 6 +-
.../operator/WindowAggregateOperatorTest.java | 83 -------
.../plan/pipeline/PipelineBreakerExecutorTest.java | 31 ++-
.../runtime/queries/ResourceBasedQueriesTest.java | 8 +-
.../service/dispatch/QueryDispatcherTest.java | 13 +-
.../query/service/server/QueryServerTest.java | 4 +-
.../src/test/resources/log4j2.xml | 3 +
52 files changed, 970 insertions(+), 1470 deletions(-)
create mode 100644
pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/executor/ExecutorServiceUtils.java
delete mode 100644
pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/executor/RoundRobinScheduler.java
create mode 100644
pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/operator/utils/AsyncStream.java
create mode 100644
pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/operator/utils/BlockingMultiStreamConsumer.java
copy pinot-spi/src/main/java/org/apache/pinot/spi/metrics/PinotMeter.java =>
pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/operator/utils/BlockingStream.java
(55%)
delete mode 100644
pinot-query-runtime/src/test/java/org/apache/pinot/query/runtime/executor/RoundRobinSchedulerTest.java
copy {pinot-broker => pinot-query-runtime}/src/test/resources/log4j2.xml (89%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
