| 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.