You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@druid.apache.org by ab...@apache.org on 2021/07/20 18:44:42 UTC
[druid] branch master updated (69b0c6a -> 94c1671)
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 69b0c6a "druid.request.logging.type" should allow "noop" value (#10774)
add 94c1671 Split SegmentLoader into SegmentLoader and SegmentCacheManager (#11466)
No new revisions were added by this update.
Summary of changes:
docs/development/modules.md | 2 +-
.../druid/indexing/kafka/KafkaIndexTaskTest.java | 4 +-
.../indexing/kinesis/KinesisIndexTaskTest.java | 4 +-
...actory.java => SegmentCacheManagerFactory.java} | 17 ++-
.../apache/druid/indexing/common/TaskToolbox.java | 10 +-
.../druid/indexing/common/TaskToolboxFactory.java | 8 +-
.../druid/indexing/common/task/CompactionTask.java | 28 ++---
.../firehose/IngestSegmentFirehoseFactory.java | 16 +--
.../druid/indexing/input/DruidInputSource.java | 16 +--
.../indexing/input/DruidSegmentInputEntity.java | 10 +-
.../druid/indexing/common/TaskToolboxTest.java | 12 +--
.../AppenderatorDriverRealtimeIndexTaskTest.java | 4 +-
.../task/ClientCompactionTaskQuerySerdeTest.java | 6 +-
.../common/task/CompactionTaskParallelRunTest.java | 18 ++--
.../common/task/CompactionTaskRunTest.java | 47 +++++----
.../indexing/common/task/CompactionTaskTest.java | 62 +++++------
.../druid/indexing/common/task/IndexTaskTest.java | 13 ++-
.../indexing/common/task/IngestionTestBase.java | 16 +--
.../common/task/RealtimeIndexTaskTest.java | 4 +-
.../AbstractMultiPhaseParallelIndexingTest.java | 7 +-
.../AbstractParallelIndexSupervisorTaskTest.java | 4 +-
.../task/batch/parallel/PartialCompactionTest.java | 2 +-
.../firehose/IngestSegmentFirehoseFactoryTest.java | 4 +-
.../IngestSegmentFirehoseFactoryTimelineTest.java | 4 +-
.../druid/indexing/input/DruidInputSourceTest.java | 12 +--
.../indexing/input/DruidSegmentReaderTest.java | 14 +--
.../overlord/SingleTaskBackgroundRunnerTest.java | 4 +-
.../druid/indexing/overlord/TaskLifecycleTest.java | 4 +-
.../indexing/worker/WorkerTaskManagerTest.java | 4 +-
.../indexing/worker/WorkerTaskMonitorTest.java | 4 +-
.../druid/guice/LocalDataStorageDruidModule.java | 7 +-
...SegmentLoader.java => SegmentCacheManager.java} | 21 ++--
.../druid/segment/loading/SegmentLoader.java | 19 ++--
.../segment/loading/SegmentLocalCacheLoader.java | 74 +++++++++++++
...eManager.java => SegmentLocalCacheManager.java} | 55 ++--------
.../org/apache/druid/server/SegmentManager.java | 5 -
.../coordination/SegmentLoadDropHandler.java | 8 +-
.../loading/CacheTestSegmentCacheManager.java | 30 +++---
.../segment/loading/CacheTestSegmentLoader.java | 25 -----
...> SegmentLocalCacheManagerConcurrencyTest.java} | 10 +-
...Test.java => SegmentLocalCacheManagerTest.java} | 115 ++++++++++-----------
...egmentManagerBroadcastJoinIndexedTableTest.java | 10 +-
.../apache/druid/server/SegmentManagerTest.java | 14 +--
.../server/SegmentManagerThreadSafetyTest.java | 15 +--
.../SegmentLoadDropHandlerCacheTest.java | 10 +-
.../coordination/SegmentLoadDropHandlerTest.java | 13 ++-
.../server/coordination/ServerManagerTest.java | 13 ---
.../server/coordination/ZkCoordinatorTest.java | 2 +
.../druid/sql/calcite/util/CalciteTests.java | 1 +
49 files changed, 403 insertions(+), 404 deletions(-)
rename indexing-service/src/main/java/org/apache/druid/indexing/common/{SegmentLoaderFactory.java => SegmentCacheManagerFactory.java} (77%)
copy server/src/main/java/org/apache/druid/segment/loading/{SegmentLoader.java => SegmentCacheManager.java} (69%)
create mode 100644 server/src/main/java/org/apache/druid/segment/loading/SegmentLocalCacheLoader.java
rename server/src/main/java/org/apache/druid/segment/loading/{SegmentLoaderLocalCacheManager.java => SegmentLocalCacheManager.java} (88%)
copy core/src/main/java/org/apache/druid/segment/loading/NoopDataSegmentPusher.java => server/src/test/java/org/apache/druid/segment/loading/CacheTestSegmentCacheManager.java (60%)
rename server/src/test/java/org/apache/druid/segment/loading/{SegmentLoaderLocalCacheManagerConcurrencyTest.java => SegmentLocalCacheManagerConcurrencyTest.java} (95%)
rename server/src/test/java/org/apache/druid/segment/loading/{SegmentLoaderLocalCacheManagerTest.java => SegmentLocalCacheManagerTest.java} (91%)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@druid.apache.org
For additional commands, e-mail: commits-help@druid.apache.org