| Modifier and Type | Method and Description | 
|---|---|
QueryRunnerFactoryConglomerate | 
TaskToolbox.getQueryRunnerFactoryConglomerate()  | 
| 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 | Class and Description | 
|---|---|
class  | 
DefaultQueryRunnerFactoryConglomerate  | 
| Constructor and Description | 
|---|
RealtimeManager(List<FireDepartment> fireDepartments,
               QueryRunnerFactoryConglomerate conglomerate,
               DataSegmentServerAnnouncer serverAnnouncer)  | 
| 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.