| Modifier and Type | Field and Description | 
|---|---|
static IndexIO | 
HadoopDruidIndexerConfig.INDEX_IO  | 
| Modifier and Type | Field and Description | 
|---|---|
static IndexIO | 
HadoopDruidConverterConfig.INDEX_IO  | 
| Modifier and Type | Method and Description | 
|---|---|
IndexIO | 
TaskToolbox.getIndexIO()  | 
| 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)  | 
| Constructor and Description | 
|---|
YeOldePlumberSchool(org.joda.time.Interval interval,
                   String version,
                   DataSegmentPusher dataSegmentPusher,
                   File tmpSegmentDir,
                   IndexMergerV9 indexMergerV9,
                   IndexIO indexIO)  | 
| Constructor and Description | 
|---|
IngestSegmentFirehoseFactory(String dataSource,
                            org.joda.time.Interval interval,
                            DimFilter dimFilter,
                            List<String> dimensions,
                            List<String> metrics,
                            IndexIO indexIO)  | 
| Constructor and Description | 
|---|
IndexMergerV9(com.fasterxml.jackson.databind.ObjectMapper mapper,
             IndexIO indexIO,
             SegmentWriteOutMediumFactory defaultSegmentWriteOutMediumFactory)  | 
| Constructor and Description | 
|---|
MMappedQueryableSegmentizerFactory(IndexIO indexIO)  | 
SegmentLoaderLocalCacheManager(IndexIO indexIO,
                              SegmentLoaderConfig config,
                              com.fasterxml.jackson.databind.ObjectMapper mapper)  | 
| Modifier and Type | Method and Description | 
|---|---|
static Appenderator | 
Appenderators.createOffline(DataSchema schema,
             AppenderatorConfig config,
             FireDepartmentMetrics metrics,
             DataSegmentPusher dataSegmentPusher,
             com.fasterxml.jackson.databind.ObjectMapper objectMapper,
             IndexIO indexIO,
             IndexMerger indexMerger)  | 
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)  | 
DefaultOfflineAppenderatorFactory(DataSegmentPusher dataSegmentPusher,
                                 com.fasterxml.jackson.databind.ObjectMapper objectMapper,
                                 IndexIO indexIO,
                                 IndexMerger indexMerger)  | 
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)  | 
| 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)  | 
Copyright © 2011–2018. All rights reserved.