This is an automated email from the ASF dual-hosted git repository.
gian pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git.
from 3daf0f8 Update ingestion-view.tsx (#9250)
add 19b427e Add JoinableFactory interface and use it in the query stack.
(#9247)
No new revisions were added by this update.
Summary of changes:
.../main/java/org/apache/druid/utils/JvmUtils.java | 20 ++-
.../druid/indexing/kafka/KafkaIndexTaskTest.java | 2 +
.../indexing/kinesis/KinesisIndexTaskTest.java | 2 +
.../apache/druid/indexing/common/TaskToolbox.java | 9 ++
.../druid/indexing/common/TaskToolboxFactory.java | 5 +
.../task/AppenderatorDriverRealtimeIndexTask.java | 1 +
.../indexing/common/task/RealtimeIndexTask.java | 1 +
.../seekablestream/SeekableStreamIndexTask.java | 1 +
.../druid/indexing/common/TaskToolboxTest.java | 2 +
.../AppenderatorDriverRealtimeIndexTaskTest.java | 2 +
.../common/task/CompactionTaskRunTest.java | 2 +
.../indexing/common/task/CompactionTaskTest.java | 2 +
.../indexing/common/task/IngestionTestBase.java | 2 +
.../common/task/RealtimeIndexTaskTest.java | 2 +
.../common/task/TestAppenderatorsManager.java | 3 +
.../AbstractParallelIndexSupervisorTaskTest.java | 2 +
.../overlord/SingleTaskBackgroundRunnerTest.java | 2 +
.../druid/indexing/overlord/TaskLifecycleTest.java | 3 +
.../indexing/worker/WorkerTaskManagerTest.java | 2 +
.../indexing/worker/WorkerTaskMonitorTest.java | 14 +-
integration-tests/docker/broker.conf | 1 +
integration-tests/docker/historical.conf | 1 +
.../resources/indexer/kafka_index_queries.json | 52 +++++++
.../indexer/wikipedia_realtime_index_queries.json | 60 ++++++++
.../queries/wikipedia_editstream_queries.json | 160 +++++++++++++++++++++
.../query/ReferenceCountingSegmentQueryRunner.java | 22 +--
.../druid/query/planning/PreJoinableClause.java | 2 +-
.../{RowAdapter.java => ReferenceCounter.java} | 22 +--
.../druid/segment/ReferenceCountingSegment.java | 12 +-
.../apache/druid/segment/join/HashJoinSegment.java | 13 +-
.../druid/segment/join/JoinConditionAnalysis.java | 20 ++-
.../org/apache/druid/segment/join/Joinable.java | 4 +
.../apache/druid/segment/join/JoinableClause.java | 4 +-
.../JoinableFactory.java} | 22 +--
.../org/apache/druid/segment/join/Joinables.java | 61 ++++++++
.../table/IndexedTableColumnSelectorFactory.java | 2 +-
.../segment/join/table/RowBasedIndexedTable.java | 5 +
.../druid/segment/join/HashJoinSegmentTest.java | 56 +++-----
.../apache/druid/segment/join/JoinablesTest.java | 78 ++++++++++
.../druid/segment/join/NoopJoinableFactory.java | 31 ++--
.../join/table/IndexedTableJoinableTest.java | 147 +++++++++++++++++++
.../druid/segment/join/DefaultJoinableFactory.java | 33 +++--
.../druid/segment/join/InlineJoinableFactory.java | 59 ++++++++
.../realtime/appenderator/Appenderators.java | 3 +
.../appenderator/AppenderatorsManager.java | 2 +
.../DefaultRealtimeAppenderatorFactory.java | 5 +
.../DummyForInjectionAppenderatorsManager.java | 2 +
.../appenderator/PeonAppenderatorsManager.java | 3 +
.../appenderator/SinkQuerySegmentWalker.java | 24 +++-
.../UnifiedIndexerAppenderatorsManager.java | 6 +
.../segment/realtime/plumber/FlushingPlumber.java | 3 +
.../realtime/plumber/FlushingPlumberSchool.java | 6 +
.../segment/realtime/plumber/RealtimePlumber.java | 3 +
.../realtime/plumber/RealtimePlumberSchool.java | 6 +
.../druid/server/coordination/ServerManager.java | 38 +++--
.../segment/join/InlineJoinableFactoryTest.java | 82 +++++++++++
.../druid/segment/realtime/FireDepartmentTest.java | 2 +
.../realtime/appenderator/AppenderatorTester.java | 2 +
.../plumber/RealtimePlumberSchoolTest.java | 2 +
.../server/coordination/ServerManagerTest.java | 2 +
.../java/org/apache/druid/cli/CliHistorical.java | 5 +-
.../main/java/org/apache/druid/cli/CliIndexer.java | 3 +
.../main/java/org/apache/druid/cli/CliPeon.java | 3 +
63 files changed, 999 insertions(+), 149 deletions(-)
copy processing/src/main/java/org/apache/druid/segment/{RowAdapter.java =>
ReferenceCounter.java} (61%)
copy processing/src/main/java/org/apache/druid/segment/{DimensionMergerV9.java
=> join/JoinableFactory.java} (59%)
copy core/src/main/java/org/apache/druid/collections/StupidResourceHolder.java
=>
processing/src/test/java/org/apache/druid/segment/join/NoopJoinableFactory.java
(66%)
create mode 100644
processing/src/test/java/org/apache/druid/segment/join/table/IndexedTableJoinableTest.java
copy
integration-tests/src/main/java/org/apache/druid/testing/IntegrationTestingCuratorConfig.java
=>
server/src/main/java/org/apache/druid/segment/join/DefaultJoinableFactory.java
(52%)
create mode 100644
server/src/main/java/org/apache/druid/segment/join/InlineJoinableFactory.java
create mode 100644
server/src/test/java/org/apache/druid/segment/join/InlineJoinableFactoryTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
