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