| Package | Description | 
|---|---|
| io.druid.client | |
| io.druid.client.cache | |
| 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 void | 
CacheUtil.populate(Cache cache,
        com.fasterxml.jackson.databind.ObjectMapper mapper,
        Cache.NamedKey key,
        Iterable<Object> results)  | 
| 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 | Class and Description | 
|---|---|
class  | 
CaffeineCache  | 
class  | 
HybridCache  | 
class  | 
MapCache  | 
class  | 
MemcachedCache  | 
class  | 
RedisCache  | 
| Modifier and Type | Method and Description | 
|---|---|
static Cache | 
MapCache.create(long sizeInBytes)  | 
Cache | 
RedisCacheProvider.get()  | 
Cache | 
MemcachedCacheProvider.get()  | 
Cache | 
LocalCacheProvider.get()
Deprecated.  
  | 
Cache | 
HybridCacheProvider.get()  | 
Cache | 
CaffeineCacheProvider.get()  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
CacheMonitor.setCache(Cache cache)  | 
| Constructor and Description | 
|---|
CacheMonitor(Cache cache)  | 
HybridCache(HybridCacheConfig config,
           Cache level1,
           Cache level2)  | 
| Modifier and Type | Method and Description | 
|---|---|
Cache | 
TaskToolbox.getCache()  | 
| Constructor and Description | 
|---|
TaskToolbox(TaskConfig config,
           TaskActionClient taskActionClient,
           ServiceEmitter emitter,
           DataSegmentPusher segmentPusher,
           DataSegmentKiller dataSegmentKiller,
           DataSegmentMover dataSegmentMover,
           DataSegmentArchiver dataSegmentArchiver,
           DataSegmentAnnouncer segmentAnnouncer,
           DataSegmentServerAnnouncer serverAnnouncer,
           SegmentHandoffNotifierFactory handoffNotifierFactory,
           com.google.inject.Provider<QueryRunnerFactoryConglomerate> queryRunnerFactoryConglomerateProvider,
           ExecutorService queryExecutorService,
           MonitorScheduler monitorScheduler,
           SegmentLoader segmentLoader,
           com.fasterxml.jackson.databind.ObjectMapper objectMapper,
           File taskWorkDir,
           IndexIO indexIO,
           Cache cache,
           CacheConfig cacheConfig,
           IndexMergerV9 indexMergerV9,
           DruidNodeAnnouncer druidNodeAnnouncer,
           DruidNode druidNode,
           LookupNodeService lookupNodeService,
           DataNodeService dataNodeService)  | 
TaskToolboxFactory(TaskConfig config,
                  TaskActionClientFactory taskActionClientFactory,
                  ServiceEmitter emitter,
                  DataSegmentPusher segmentPusher,
                  DataSegmentKiller dataSegmentKiller,
                  DataSegmentMover dataSegmentMover,
                  DataSegmentArchiver dataSegmentArchiver,
                  DataSegmentAnnouncer segmentAnnouncer,
                  DataSegmentServerAnnouncer serverAnnouncer,
                  SegmentHandoffNotifierFactory handoffNotifierFactory,
                  com.google.inject.Provider<QueryRunnerFactoryConglomerate> queryRunnerFactoryConglomerateProvider,
                  ExecutorService queryExecutorService,
                  MonitorScheduler monitorScheduler,
                  SegmentLoaderFactory segmentLoaderFactory,
                  com.fasterxml.jackson.databind.ObjectMapper objectMapper,
                  IndexIO indexIO,
                  Cache cache,
                  CacheConfig cacheConfig,
                  IndexMergerV9 indexMergerV9,
                  DruidNodeAnnouncer druidNodeAnnouncer,
                  DruidNode druidNode,
                  LookupNodeService lookupNodeService,
                  DataNodeService dataNodeService)  | 
| 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)  | 
| Constructor and Description | 
|---|
AppenderatorImpl(DataSchema schema,
                AppenderatorConfig tuningConfig,
                FireDepartmentMetrics metrics,
                DataSegmentPusher dataSegmentPusher,
                com.fasterxml.jackson.databind.ObjectMapper objectMapper,
                QueryRunnerFactoryConglomerate conglomerate,
                DataSegmentAnnouncer segmentAnnouncer,
                ServiceEmitter emitter,
                ExecutorService queryExecutorService,
                IndexIO indexIO,
                IndexMerger indexMerger,
                Cache cache,
                CacheConfig cacheConfig)  | 
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)  | 
SinkQuerySegmentWalker(String dataSource,
                      VersionedIntervalTimeline<String,Sink> sinkTimeline,
                      com.fasterxml.jackson.databind.ObjectMapper objectMapper,
                      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,
               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,
                     ServiceEmitter emitter,
                     QueryRunnerFactoryConglomerate conglomerate,
                     DataSegmentAnnouncer segmentAnnouncer,
                     ExecutorService queryExecutorService,
                     IndexMergerV9 indexMergerV9,
                     IndexIO indexIO,
                     Cache cache,
                     CacheConfig cacheConfig,
                     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,
               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,
                     com.fasterxml.jackson.databind.ObjectMapper objectMapper)  | 
| Constructor and Description | 
|---|
ServerManager(QueryRunnerFactoryConglomerate conglomerate,
             ServiceEmitter emitter,
             ExecutorService exec,
             ExecutorService cachingExec,
             com.fasterxml.jackson.databind.ObjectMapper objectMapper,
             Cache cache,
             CacheConfig cacheConfig,
             SegmentManager segmentManager,
             ServerConfig serverConfig)  | 
Copyright © 2011–2018. All rights reserved.