Uses of Interface
org.apache.druid.segment.realtime.plumber.Plumber

Packages that use Plumber

Package	Description
org.apache.druid.segment.realtime
org.apache.druid.segment.realtime.appenderator
org.apache.druid.segment.realtime.plumber

Uses of Plumber in org.apache.druid.segment.realtime

Methods in org.apache.druid.segment.realtime that return Plumber

Modifier and Type	Method and Description
Plumber	FireDepartment.findPlumber()

Uses of Plumber in org.apache.druid.segment.realtime.appenderator

Classes in org.apache.druid.segment.realtime.appenderator that implement Plumber

Modifier and Type	Class and Description
class	AppenderatorPlumber

Methods in org.apache.druid.segment.realtime.appenderator that return Plumber

Modifier and Type	Method and Description
Plumber	AppenderatorPlumberSchool.findPlumber(DataSchema schema, RealtimeTuningConfig config, FireDepartmentMetrics metrics)

Uses of Plumber in org.apache.druid.segment.realtime.plumber

Classes in org.apache.druid.segment.realtime.plumber that implement Plumber

Modifier and Type	Class and Description
class	FlushingPlumber
class	RealtimePlumber

Methods in org.apache.druid.segment.realtime.plumber that return Plumber

Modifier and Type	Method and Description
Plumber	PlumberSchool.findPlumber(DataSchema schema, RealtimeTuningConfig config, FireDepartmentMetrics metrics) Creates a Plumber
Plumber	RealtimePlumberSchool.findPlumber(DataSchema schema, RealtimeTuningConfig config, FireDepartmentMetrics metrics)
Plumber	FlushingPlumberSchool.findPlumber(DataSchema schema, RealtimeTuningConfig config, FireDepartmentMetrics metrics)

Methods in org.apache.druid.segment.realtime.plumber with parameters of type Plumber

Modifier and Type	Method and Description
static void	Plumbers.addNextRow(com.google.common.base.Supplier<org.apache.druid.data.input.Committer> committerSupplier, org.apache.druid.data.input.Firehose firehose, Plumber plumber, boolean reportParseExceptions, FireDepartmentMetrics metrics)