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.