| Package | Description |
|---|---|
| org.apache.druid.client.cache | |
| org.apache.druid.guice | |
| org.apache.druid.segment.realtime.appenderator | |
| org.apache.druid.segment.realtime.plumber |
| Constructor and Description |
|---|
BackgroundCachePopulator(ExecutorService exec,
com.fasterxml.jackson.databind.ObjectMapper objectMapper,
CachePopulatorStats cachePopulatorStats,
long maxEntrySize) |
CacheMonitor(CachePopulatorStats cachePopulatorStats) |
ForegroundCachePopulator(com.fasterxml.jackson.databind.ObjectMapper objectMapper,
CachePopulatorStats cachePopulatorStats,
long maxEntrySize) |
| Modifier and Type | Method and Description |
|---|---|
CachePopulator |
DruidProcessingModule.getCachePopulator(com.fasterxml.jackson.databind.ObjectMapper smileMapper,
CachePopulatorStats cachePopulatorStats,
CacheConfig cacheConfig) |
| Modifier and Type | Method and Description |
|---|---|
static Appenderator |
Appenderators.createRealtime(DataSchema schema,
AppenderatorConfig config,
FireDepartmentMetrics metrics,
DataSegmentPusher dataSegmentPusher,
com.fasterxml.jackson.databind.ObjectMapper objectMapper,
IndexIO indexIO,
IndexMerger indexMerger,
QueryRunnerFactoryConglomerate conglomerate,
DataSegmentAnnouncer segmentAnnouncer,
ServiceEmitter emitter,
ExecutorService queryExecutorService,
Cache cache,
CacheConfig cacheConfig,
CachePopulatorStats cachePopulatorStats) |
| Constructor and Description |
|---|
DefaultRealtimeAppenderatorFactory(ServiceEmitter emitter,
QueryRunnerFactoryConglomerate conglomerate,
DataSegmentAnnouncer segmentAnnouncer,
ExecutorService queryExecutorService,
DataSegmentPusher dataSegmentPusher,
com.fasterxml.jackson.databind.ObjectMapper objectMapper,
IndexIO indexIO,
IndexMerger indexMerger,
Cache cache,
CacheConfig cacheConfig,
CachePopulatorStats cachePopulatorStats) |
SinkQuerySegmentWalker(String dataSource,
org.apache.druid.timeline.VersionedIntervalTimeline<String,Sink> sinkTimeline,
com.fasterxml.jackson.databind.ObjectMapper objectMapper,
ServiceEmitter emitter,
QueryRunnerFactoryConglomerate conglomerate,
ExecutorService queryExecutorService,
Cache cache,
CacheConfig cacheConfig,
CachePopulatorStats cachePopulatorStats) |
| Constructor and Description |
|---|
FlushingPlumber(org.joda.time.Duration flushDuration,
DataSchema schema,
RealtimeTuningConfig config,
FireDepartmentMetrics metrics,
ServiceEmitter emitter,
QueryRunnerFactoryConglomerate conglomerate,
DataSegmentAnnouncer segmentAnnouncer,
ExecutorService queryExecutorService,
IndexMerger indexMerger,
IndexIO indexIO,
Cache cache,
CacheConfig cacheConfig,
CachePopulatorStats cachePopulatorStats,
com.fasterxml.jackson.databind.ObjectMapper objectMapper) |
FlushingPlumberSchool(org.joda.time.Duration flushDuration,
ServiceEmitter emitter,
QueryRunnerFactoryConglomerate conglomerate,
DataSegmentAnnouncer segmentAnnouncer,
ExecutorService queryExecutorService,
IndexMergerV9 indexMergerV9,
IndexIO indexIO,
Cache cache,
CacheConfig cacheConfig,
CachePopulatorStats cachePopulatorStats,
com.fasterxml.jackson.databind.ObjectMapper objectMapper) |
RealtimePlumber(DataSchema schema,
RealtimeTuningConfig config,
FireDepartmentMetrics metrics,
ServiceEmitter emitter,
QueryRunnerFactoryConglomerate conglomerate,
DataSegmentAnnouncer segmentAnnouncer,
ExecutorService queryExecutorService,
DataSegmentPusher dataSegmentPusher,
SegmentPublisher segmentPublisher,
SegmentHandoffNotifier handoffNotifier,
IndexMerger indexMerger,
IndexIO indexIO,
Cache cache,
CacheConfig cacheConfig,
CachePopulatorStats cachePopulatorStats,
com.fasterxml.jackson.databind.ObjectMapper objectMapper) |
RealtimePlumberSchool(ServiceEmitter emitter,
QueryRunnerFactoryConglomerate conglomerate,
DataSegmentPusher dataSegmentPusher,
DataSegmentAnnouncer segmentAnnouncer,
SegmentPublisher segmentPublisher,
SegmentHandoffNotifierFactory handoffNotifierFactory,
ExecutorService executorService,
IndexMergerV9 indexMergerV9,
IndexIO indexIO,
Cache cache,
CacheConfig cacheConfig,
CachePopulatorStats cachePopulatorStats,
com.fasterxml.jackson.databind.ObjectMapper objectMapper) |
Copyright © 2011–2018 The Apache Software Foundation. All rights reserved.