Package | Description |
---|---|
io.druid.indexing.common.index | |
io.druid.segment.indexing | |
io.druid.segment.realtime | |
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() |
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 |
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) |
RealtimePlumber(DataSchema schema,
RealtimeTuningConfig config,
FireDepartmentMetrics metrics,
com.metamx.emitter.service.ServiceEmitter emitter,
QueryRunnerFactoryConglomerate conglomerate,
DataSegmentAnnouncer segmentAnnouncer,
ExecutorService queryExecutorService,
io.druid.segment.loading.DataSegmentPusher dataSegmentPusher,
SegmentPublisher segmentPublisher,
FilteredServerView serverView) |
Sink(org.joda.time.Interval interval,
DataSchema schema,
RealtimeTuningConfig config,
String version) |
Sink(org.joda.time.Interval interval,
DataSchema schema,
RealtimeTuningConfig config,
String version,
List<FireHydrant> hydrants) |
Copyright © 2011–2015. All rights reserved.