Package io.druid.data.input

Interface Summary

Interface	Description
ByteBufferInputRowParser
Committer	Committer includes a Runnable and a Jackson-serialized metadata object containing the offset
Firehose	This is an interface that holds onto the stream of incoming data.
FirehoseFactory<T extends InputRowParser>	FirehoseFactory creates a Firehose which is an interface holding onto the stream of incoming data.
FirehoseFactoryV2<T extends InputRowParser>	Initialization method that connects up the FirehoseV2.
FirehoseV2	This is an interface that holds onto the stream of incoming data.
InputRow	An InputRow is the interface definition of an event being input into the data ingestion layer.
Row	A Row of data.

Class Summary

Class	Description
AvroHadoopInputRowParser
AvroStreamInputRowParser
MapBasedInputRow
MapBasedRow
MapPopulator<K,V>	Simple class that takes a `ByteSource` and uses a `Parser` to populate a `Map` The `ByteSource` must be UTF-8 encoded
MapPopulator.PopulateResult
Rows