This is an automated email from the ASF dual-hosted git repository.
abhishek pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git.
from 906a704 Eliminate ambiguities of KB/MB/GB in the doc (#11333)
add 03a6a6d Replace Processing ExecutorService with QueryProcessingPool
(#11382)
No new revisions were added by this update.
Summary of changes:
.../druid/indexing/kafka/KafkaIndexTaskTest.java | 3 +-
.../indexing/kinesis/KinesisIndexTaskTest.java | 3 +-
.../apache/druid/indexing/common/TaskToolbox.java | 12 ++--
.../druid/indexing/common/TaskToolboxFactory.java | 11 ++--
.../task/AppenderatorDriverRealtimeIndexTask.java | 2 +-
.../indexing/common/task/RealtimeIndexTask.java | 2 +-
.../seekablestream/SeekableStreamIndexTask.java | 2 +-
.../druid/indexing/common/TaskToolboxTest.java | 10 +--
.../AppenderatorDriverRealtimeIndexTaskTest.java | 3 +-
.../common/task/RealtimeIndexTaskTest.java | 3 +-
.../common/task/TestAppenderatorsManager.java | 7 +--
.../druid/indexing/overlord/TaskLifecycleTest.java | 8 ++-
.../ServerManagerForQueryErrorTest.java | 9 ++-
.../apache/druid/guice/annotations/Processing.java | 36 -----------
...=> AbstractPrioritizedQueryRunnerCallable.java} | 17 ++++-
.../java/org/apache/druid/query/CacheStrategy.java | 3 +-
.../druid/query/ChainedExecutionQueryRunner.java | 27 ++------
.../druid/query/DirectQueryProcessingPool.java | 32 +++++-----
...ice.java => ForwardingQueryProcessingPool.java} | 44 ++++---------
.../druid/query/GroupByMergedQueryRunner.java | 17 +++--
...ava => MetricsEmittingQueryProcessingPool.java} | 35 ++---------
.../query/PrioritizedQueryRunnerCallable.java | 37 +++++++++++
.../main/java/org/apache/druid/query/Query.java | 3 +-
.../apache/druid/query/QueryProcessingPool.java | 51 +++++++++++++++
.../org/apache/druid/query/QueryRunnerFactory.java | 33 +++++++++-
.../DataSourceMetadataQueryRunnerFactory.java | 6 +-
.../query/groupby/GroupByQueryRunnerFactory.java | 12 +---
.../epinephelinae/GroupByMergingQueryRunnerV2.java | 24 ++++----
.../query/groupby/strategy/GroupByStrategy.java | 17 +++--
.../query/groupby/strategy/GroupByStrategyV1.java | 6 +-
.../query/groupby/strategy/GroupByStrategyV2.java | 6 +-
.../SegmentMetadataQueryRunnerFactory.java | 13 ++--
.../druid/query/scan/ScanQueryRunnerFactory.java | 4 +-
.../query/search/SearchQueryRunnerFactory.java | 7 +--
.../TimeBoundaryQueryRunnerFactory.java | 6 +-
.../timeseries/TimeseriesQueryRunnerFactory.java | 7 +--
.../druid/query/topn/TopNQueryRunnerFactory.java | 6 +-
.../query/ChainedExecutionQueryRunnerTest.java | 43 ++++++++++++-
.../MetricsEmittingQueryProcessingPoolTest.java | 72 ++++++++++++++++++++++
.../query/groupby/GroupByQueryRunnerTest.java | 3 +-
.../apache/druid/guice/DruidProcessingModule.java | 9 ++-
.../apache/druid/guice/RouterProcessingModule.java | 9 ++-
.../realtime/appenderator/Appenderators.java | 7 +--
.../appenderator/AppenderatorsManager.java | 5 +-
.../DefaultRealtimeAppenderatorFactory.java | 11 ++--
.../DummyForInjectionAppenderatorsManager.java | 5 +-
.../appenderator/PeonAppenderatorsManager.java | 7 +--
.../appenderator/SinkQuerySegmentWalker.java | 14 ++---
.../UnifiedIndexerAppenderatorsManager.java | 13 ++--
.../segment/realtime/plumber/FlushingPlumber.java | 6 +-
.../realtime/plumber/FlushingPlumberSchool.java | 14 ++---
.../segment/realtime/plumber/RealtimePlumber.java | 5 +-
.../realtime/plumber/RealtimePlumberSchool.java | 12 ++--
.../druid/server/LocalQuerySegmentWalker.java | 4 +-
.../druid/server/coordination/ServerManager.java | 11 ++--
.../realtime/appenderator/AppenderatorTester.java | 3 +-
.../UnifiedIndexerAppenderatorsManagerTest.java | 4 +-
.../plumber/RealtimePlumberSchoolTest.java | 4 +-
.../server/coordination/ServerManagerTest.java | 7 ++-
.../java/org/apache/druid/cli/DumpSegment.java | 8 ++-
.../java/org/apache/druid/cli/DumpSegmentTest.java | 58 +++++++++++++++++
61 files changed, 520 insertions(+), 338 deletions(-)
delete mode 100644
processing/src/main/java/org/apache/druid/guice/annotations/Processing.java
copy
processing/src/main/java/org/apache/druid/query/{AbstractPrioritizedCallable.java
=> AbstractPrioritizedQueryRunnerCallable.java} (67%)
copy
core/src/main/java/org/apache/druid/java/util/http/client/CredentialedHttpClient.java
=>
processing/src/main/java/org/apache/druid/query/DirectQueryProcessingPool.java
(53%)
copy
processing/src/main/java/org/apache/druid/query/{MetricsEmittingExecutorService.java
=> ForwardingQueryProcessingPool.java} (53%)
rename
processing/src/main/java/org/apache/druid/query/{MetricsEmittingExecutorService.java
=> MetricsEmittingQueryProcessingPool.java} (62%)
create mode 100644
processing/src/main/java/org/apache/druid/query/PrioritizedQueryRunnerCallable.java
create mode 100644
processing/src/main/java/org/apache/druid/query/QueryProcessingPool.java
create mode 100644
processing/src/test/java/org/apache/druid/query/MetricsEmittingQueryProcessingPoolTest.java
create mode 100644
services/src/test/java/org/apache/druid/cli/DumpSegmentTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
