Package io.druid.segment.realtime.firehose

Interface Summary

Interface	Description
ChatHandler	Objects that can be registered with a ServiceAnnouncingChatHandlerProvider and provide http endpoints for indexing-related objects.
ChatHandlerProvider
EventReceiver
IrcDecoder

Class Summary

Class	Description
ChatHandlerResource
ClippedFirehoseFactory	Creates firehoses clipped to a particular time interval.
CombiningFirehoseFactory	Creates firehose that combines data from different Firehoses.
EventReceiverFirehoseFactory	Builds firehoses that accept events through the EventReceiver interface.
FixedCountFirehoseFactory	Firehose to give out only first n events from the delegate firehose.
IngestSegmentFirehose
IrcFirehoseFactory	Example code:
IrcInputRowParser	Example Usage
LocalFirehoseFactory
NoopChatHandlerProvider
PredicateFirehose	Provides a view on a firehose that only returns rows that match a certain predicate.
ReplayableFirehoseFactory	Creates a wrapper firehose that writes from another firehose to disk and then serves nextRow() from disk.
ServiceAnnouncingChatHandlerProvider	Provides a way for the outside world to talk to objects in the indexing service.
TimedShutoffFirehoseFactory	Creates firehoses that shut off at a particular time.
WindowedStorageAdapter