Package | Description |
---|---|
io.druid.indexing.common.index | |
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 |
---|---|
Plumber |
FireDepartment.findPlumber() |
Modifier and Type | Class and Description |
---|---|
class |
AppenderatorPlumber |
Modifier and Type | Method and Description |
---|---|
Plumber |
AppenderatorPlumberSchool.findPlumber(DataSchema schema,
RealtimeTuningConfig config,
FireDepartmentMetrics metrics) |
Modifier and Type | Class and Description |
---|---|
class |
FlushingPlumber |
class |
RealtimePlumber |
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) |
Modifier and Type | Method and Description |
---|---|
static void |
Plumbers.addNextRow(com.google.common.base.Supplier<Committer> committerSupplier,
Firehose firehose,
Plumber plumber,
boolean reportParseExceptions,
FireDepartmentMetrics metrics) |
Copyright © 2011–2017. All rights reserved.