| Modifier and Type | Method and Description | 
|---|---|
static com.google.inject.multibindings.MapBinder<String,DataSegmentPusher> | 
Binders.dataSegmentPusherBinder(com.google.inject.Binder binder)  | 
| Modifier and Type | Field and Description | 
|---|---|
static DataSegmentPusher | 
HadoopDruidIndexerConfig.DATA_SEGMENT_PUSHER  | 
| Modifier and Type | Method and Description | 
|---|---|
static org.apache.hadoop.fs.Path | 
JobHelper.makeFileNamePath(org.apache.hadoop.fs.Path basePath,
                org.apache.hadoop.fs.FileSystem fs,
                DataSegment segmentTemplate,
                String baseFileName,
                DataSegmentPusher dataSegmentPusher)  | 
static org.apache.hadoop.fs.Path | 
JobHelper.makeTmpPath(org.apache.hadoop.fs.Path basePath,
           org.apache.hadoop.fs.FileSystem fs,
           DataSegment segmentTemplate,
           org.apache.hadoop.mapreduce.TaskAttemptID taskAttemptID,
           DataSegmentPusher dataSegmentPusher)  | 
static DataSegment | 
JobHelper.serializeOutIndex(DataSegment segmentTemplate,
                 org.apache.hadoop.conf.Configuration configuration,
                 org.apache.hadoop.util.Progressable progressable,
                 File mergedBase,
                 org.apache.hadoop.fs.Path finalIndexZipFilePath,
                 org.apache.hadoop.fs.Path finalDescriptorPath,
                 org.apache.hadoop.fs.Path tmpPath,
                 DataSegmentPusher dataSegmentPusher)  | 
| Modifier and Type | Field and Description | 
|---|---|
static DataSegmentPusher | 
HadoopDruidConverterConfig.DATA_SEGMENT_PUSHER  | 
| Modifier and Type | Method and Description | 
|---|---|
DataSegmentPusher | 
TaskToolbox.getSegmentPusher()  | 
| 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)  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
LocalDataSegmentPusher  | 
| 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 | 
|---|
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)  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
AzureDataSegmentPusher  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
CassandraDataSegmentPusher
Cassandra Segment Pusher 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
CloudFilesDataSegmentPusher  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
GoogleDataSegmentPusher  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
HdfsDataSegmentPusher  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
S3DataSegmentPusher  | 
Copyright © 2011–2018. All rights reserved.