Package | Description |
---|---|
io.druid.indexing.common.index | |
io.druid.segment.indexing | |
io.druid.segment.realtime | |
io.druid.segment.realtime.appenderator | |
io.druid.segment.realtime.plumber |
Modifier and Type | Method and Description |
---|---|
Plumber |
YeOldePlumberSchool.findPlumber(DataSchema schema,
RealtimeTuningConfig config,
FireDepartmentMetrics metrics) |
Modifier and Type | Method and Description |
---|---|
static RealtimeTuningConfig |
RealtimeTuningConfig.makeDefaultTuningConfig(File basePersistDirectory) |
RealtimeTuningConfig |
RealtimeTuningConfig.withBasePersistDirectory(File dir) |
RealtimeTuningConfig |
RealtimeTuningConfig.withVersioningPolicy(VersioningPolicy policy) |
Modifier and Type | Method and Description |
---|---|
RealtimeTuningConfig |
FireDepartment.getTuningConfig() |
Constructor and Description |
---|
FireDepartment(DataSchema dataSchema,
RealtimeIOConfig ioConfig,
RealtimeTuningConfig tuningConfig) |
Modifier and Type | Method and Description |
---|---|
RealtimeTuningConfig |
AppenderatorPlumber.getConfig() |
Modifier and Type | Method and Description |
---|---|
Appenderator |
DefaultRealtimeAppenderatorFactory.build(DataSchema schema,
RealtimeTuningConfig config,
FireDepartmentMetrics metrics) |
Appenderator |
DefaultOfflineAppenderatorFactory.build(DataSchema schema,
RealtimeTuningConfig config,
FireDepartmentMetrics metrics) |
Appenderator |
AppenderatorFactory.build(DataSchema schema,
RealtimeTuningConfig config,
FireDepartmentMetrics metrics) |
Plumber |
AppenderatorPlumberSchool.findPlumber(DataSchema schema,
RealtimeTuningConfig config,
FireDepartmentMetrics metrics) |
Constructor and Description |
---|
AppenderatorPlumber(DataSchema schema,
RealtimeTuningConfig config,
FireDepartmentMetrics metrics,
DataSegmentAnnouncer segmentAnnouncer,
SegmentPublisher segmentPublisher,
SegmentHandoffNotifier handoffNotifier,
Appenderator appenderator) |
Modifier and Type | Method and Description |
---|---|
RealtimeTuningConfig |
RealtimePlumber.getConfig() |
Modifier and Type | Method and Description |
---|---|
Plumber |
RealtimePlumberSchool.findPlumber(DataSchema schema,
RealtimeTuningConfig config,
FireDepartmentMetrics metrics) |
Plumber |
PlumberSchool.findPlumber(DataSchema schema,
RealtimeTuningConfig config,
FireDepartmentMetrics metrics)
Creates a Plumber
|
Plumber |
FlushingPlumberSchool.findPlumber(DataSchema schema,
RealtimeTuningConfig config,
FireDepartmentMetrics metrics) |
Constructor and Description |
---|
FlushingPlumber(org.joda.time.Duration flushDuration,
DataSchema schema,
RealtimeTuningConfig config,
FireDepartmentMetrics metrics,
com.metamx.emitter.service.ServiceEmitter emitter,
QueryRunnerFactoryConglomerate conglomerate,
DataSegmentAnnouncer segmentAnnouncer,
ExecutorService queryExecutorService,
IndexMerger indexMerger,
IndexIO indexIO,
Cache cache,
CacheConfig cacheConfig,
com.fasterxml.jackson.databind.ObjectMapper objectMapper) |
RealtimePlumber(DataSchema schema,
RealtimeTuningConfig config,
FireDepartmentMetrics metrics,
com.metamx.emitter.service.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) |
Copyright © 2011–2017. All rights reserved.