io.druid.segment.realtime

Class FireDepartment

java.lang.Object

io.druid.segment.indexing.IngestionSpec<RealtimeIOConfig,RealtimeTuningConfig>

io.druid.segment.realtime.FireDepartment

public class FireDepartment
extends IngestionSpec<RealtimeIOConfig,RealtimeTuningConfig>

A Fire Department has a Firehose and a Plumber. This is a metaphor for a realtime stream (Firehose) and a coordinator of sinks (Plumber). The Firehose provides the realtime stream of data. The Plumber directs each drop of water from the firehose into the correct sink and makes sure that the sinks don't overflow.

Constructor Summary

Constructors

Constructor and Description
FireDepartment(DataSchema dataSchema, RealtimeIOConfig ioConfig, RealtimeTuningConfig tuningConfig, Schema schema, FireDepartmentConfig config, io.druid.data.input.FirehoseFactory firehoseFactory, PlumberSchool plumberSchool)

Method Summary

Methods

Modifier and Type	Method and Description
io.druid.data.input.Firehose	connect()
Plumber	findPlumber()
DataSchema	getDataSchema() Provides the data schema for the feed that this FireDepartment is in charge of.
RealtimeIOConfig	getIOConfig()
FireDepartmentMetrics	getMetrics()
RealtimeTuningConfig	getTuningConfig()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

FireDepartment

public FireDepartment(DataSchema dataSchema,
              RealtimeIOConfig ioConfig,
              RealtimeTuningConfig tuningConfig,
              Schema schema,
              FireDepartmentConfig config,
              io.druid.data.input.FirehoseFactory firehoseFactory,
              PlumberSchool plumberSchool)

Method Detail

getDataSchema

public DataSchema getDataSchema()

Provides the data schema for the feed that this FireDepartment is in charge of.

Overrides:

getDataSchema in class IngestionSpec<RealtimeIOConfig,RealtimeTuningConfig>

Returns:

the Schema for this feed.

getIOConfig

public RealtimeIOConfig getIOConfig()

Overrides:

getIOConfig in class IngestionSpec<RealtimeIOConfig,RealtimeTuningConfig>

getTuningConfig

public RealtimeTuningConfig getTuningConfig()

Overrides:

getTuningConfig in class IngestionSpec<RealtimeIOConfig,RealtimeTuningConfig>

findPlumber

public Plumber findPlumber()

connect

public io.druid.data.input.Firehose connect()
                                     throws IOException

Throws:

IOException

getMetrics

public FireDepartmentMetrics getMetrics()