Package | Description |
---|---|
io.druid.indexing.common.index | |
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 |
---|---|
FireDepartmentMetrics |
FireDepartment.getMetrics() |
FireDepartmentMetrics |
RealtimeManager.getMetrics(String datasource) |
FireDepartmentMetrics |
FireDepartmentMetrics.merge(FireDepartmentMetrics other)
merge other FireDepartmentMetrics, will modify this object's data
|
FireDepartmentMetrics |
FireDepartmentMetrics.snapshot() |
Modifier and Type | Method and Description |
---|---|
FireDepartmentMetrics |
FireDepartmentMetrics.merge(FireDepartmentMetrics other)
merge other FireDepartmentMetrics, will modify this object's data
|
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) |
Copyright © 2011–2015. All rights reserved.