Package | Description |
---|---|
io.druid.client | |
io.druid.guice | |
io.druid.indexing.common | |
io.druid.segment.realtime.appenderator | |
io.druid.segment.realtime.plumber | |
io.druid.server.coordination |
Modifier and Type | Method and Description |
---|---|
static <T> boolean |
CacheUtil.populateCacheOnBrokers(Query<T> query,
CacheStrategy<T,Object,Query<T>> strategy,
CacheConfig cacheConfig) |
static <T> boolean |
CacheUtil.populateCacheOnDataNodes(Query<T> query,
CacheStrategy<T,Object,Query<T>> strategy,
CacheConfig cacheConfig) |
static <T> boolean |
CacheUtil.useCacheOnBrokers(Query<T> query,
CacheStrategy<T,Object,Query<T>> strategy,
CacheConfig cacheConfig) |
static <T> boolean |
CacheUtil.useCacheOnDataNodes(Query<T> query,
CacheStrategy<T,Object,Query<T>> strategy,
CacheConfig cacheConfig) |
Constructor and Description |
---|
CachingClusteredClient(QueryToolChestWarehouse warehouse,
TimelineServerView serverView,
Cache cache,
com.fasterxml.jackson.databind.ObjectMapper objectMapper,
ExecutorService backgroundExecutorService,
CacheConfig cacheConfig) |
CachingQueryRunner(String segmentIdentifier,
SegmentDescriptor segmentDescriptor,
com.fasterxml.jackson.databind.ObjectMapper mapper,
Cache cache,
QueryToolChest toolchest,
QueryRunner<T> base,
ExecutorService backgroundExecutorService,
CacheConfig cacheConfig) |
Modifier and Type | Method and Description |
---|---|
ExecutorService |
DruidProcessingModule.getBackgroundExecutorService(CacheConfig cacheConfig) |
Modifier and Type | Method and Description |
---|---|
CacheConfig |
TaskToolbox.getCacheConfig() |
Constructor and Description |
---|
TaskToolbox(TaskConfig config,
Task task,
TaskActionClient taskActionClient,
com.metamx.emitter.service.ServiceEmitter emitter,
DataSegmentPusher segmentPusher,
DataSegmentKiller dataSegmentKiller,
DataSegmentMover dataSegmentMover,
DataSegmentArchiver dataSegmentArchiver,
DataSegmentAnnouncer segmentAnnouncer,
SegmentHandoffNotifierFactory handoffNotifierFactory,
QueryRunnerFactoryConglomerate queryRunnerFactoryConglomerate,
ExecutorService queryExecutorService,
com.metamx.metrics.MonitorScheduler monitorScheduler,
SegmentLoader segmentLoader,
com.fasterxml.jackson.databind.ObjectMapper objectMapper,
File taskWorkDir,
IndexMerger indexMerger,
IndexIO indexIO,
Cache cache,
CacheConfig cacheConfig,
IndexMergerV9 indexMergerV9) |
TaskToolboxFactory(TaskConfig config,
TaskActionClientFactory taskActionClientFactory,
com.metamx.emitter.service.ServiceEmitter emitter,
DataSegmentPusher segmentPusher,
DataSegmentKiller dataSegmentKiller,
DataSegmentMover dataSegmentMover,
DataSegmentArchiver dataSegmentArchiver,
DataSegmentAnnouncer segmentAnnouncer,
SegmentHandoffNotifierFactory handoffNotifierFactory,
QueryRunnerFactoryConglomerate queryRunnerFactoryConglomerate,
ExecutorService queryExecutorService,
com.metamx.metrics.MonitorScheduler monitorScheduler,
SegmentLoaderFactory segmentLoaderFactory,
com.fasterxml.jackson.databind.ObjectMapper objectMapper,
IndexMerger indexMerger,
IndexIO indexIO,
Cache cache,
CacheConfig cacheConfig,
IndexMergerV9 indexMergerV9) |
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,
com.metamx.emitter.service.ServiceEmitter emitter,
ExecutorService queryExecutorService,
Cache cache,
CacheConfig cacheConfig) |
Constructor and Description |
---|
AppenderatorImpl(DataSchema schema,
AppenderatorConfig tuningConfig,
FireDepartmentMetrics metrics,
DataSegmentPusher dataSegmentPusher,
com.fasterxml.jackson.databind.ObjectMapper objectMapper,
QueryRunnerFactoryConglomerate conglomerate,
DataSegmentAnnouncer segmentAnnouncer,
com.metamx.emitter.service.ServiceEmitter emitter,
ExecutorService queryExecutorService,
IndexIO indexIO,
IndexMerger indexMerger,
Cache cache,
CacheConfig cacheConfig) |
DefaultRealtimeAppenderatorFactory(com.metamx.emitter.service.ServiceEmitter emitter,
QueryRunnerFactoryConglomerate conglomerate,
DataSegmentAnnouncer segmentAnnouncer,
ExecutorService queryExecutorService,
DataSegmentPusher dataSegmentPusher,
com.fasterxml.jackson.databind.ObjectMapper objectMapper,
IndexIO indexIO,
IndexMerger indexMerger,
Cache cache,
CacheConfig cacheConfig) |
SinkQuerySegmentWalker(String dataSource,
VersionedIntervalTimeline<String,Sink> sinkTimeline,
com.fasterxml.jackson.databind.ObjectMapper objectMapper,
com.metamx.emitter.service.ServiceEmitter emitter,
QueryRunnerFactoryConglomerate conglomerate,
ExecutorService queryExecutorService,
Cache cache,
CacheConfig cacheConfig) |
Constructor and Description |
---|
FlushingPlumber(org.joda.time.Duration flushDuration,
DataSchema schema,
RealtimeTuningConfig config,
FireDepartmentMetrics metrics,
com.metamx.emitter.service.ServiceEmitter emitter,
QueryRunnerFactoryConglomerate conglomerate,
DataSegmentAnnouncer segmentAnnouncer,
ExecutorService queryExecutorService,
IndexMerger indexMerger,
IndexIO indexIO,
Cache cache,
CacheConfig cacheConfig,
com.fasterxml.jackson.databind.ObjectMapper objectMapper) |
FlushingPlumberSchool(org.joda.time.Duration flushDuration,
com.metamx.emitter.service.ServiceEmitter emitter,
QueryRunnerFactoryConglomerate conglomerate,
DataSegmentAnnouncer segmentAnnouncer,
ExecutorService queryExecutorService,
IndexMerger indexMerger,
IndexMergerV9 indexMergerV9,
IndexIO indexIO,
Cache cache,
CacheConfig cacheConfig,
com.fasterxml.jackson.databind.ObjectMapper objectMapper) |
RealtimePlumber(DataSchema schema,
RealtimeTuningConfig config,
FireDepartmentMetrics metrics,
com.metamx.emitter.service.ServiceEmitter emitter,
QueryRunnerFactoryConglomerate conglomerate,
DataSegmentAnnouncer segmentAnnouncer,
ExecutorService queryExecutorService,
DataSegmentPusher dataSegmentPusher,
SegmentPublisher segmentPublisher,
SegmentHandoffNotifier handoffNotifier,
IndexMerger indexMerger,
IndexIO indexIO,
Cache cache,
CacheConfig cacheConfig,
com.fasterxml.jackson.databind.ObjectMapper objectMapper) |
RealtimePlumberSchool(com.metamx.emitter.service.ServiceEmitter emitter,
QueryRunnerFactoryConglomerate conglomerate,
DataSegmentPusher dataSegmentPusher,
DataSegmentAnnouncer segmentAnnouncer,
SegmentPublisher segmentPublisher,
SegmentHandoffNotifierFactory handoffNotifierFactory,
ExecutorService executorService,
IndexMerger indexMerger,
IndexMergerV9 indexMergerV9,
IndexIO indexIO,
Cache cache,
CacheConfig cacheConfig,
com.fasterxml.jackson.databind.ObjectMapper objectMapper) |
Constructor and Description |
---|
ServerManager(SegmentLoader segmentLoader,
QueryRunnerFactoryConglomerate conglomerate,
com.metamx.emitter.service.ServiceEmitter emitter,
ExecutorService exec,
ExecutorService cachingExec,
com.fasterxml.jackson.databind.ObjectMapper objectMapper,
Cache cache,
CacheConfig cacheConfig) |
Copyright © 2011–2017. All rights reserved.