io.druid.data.input

Interface FirehoseFactory<T extends InputRowParser>

All Known Implementing Classes:

ClippedFirehoseFactory, CombiningFirehoseFactory, EventReceiverFirehoseFactory, FixedCountFirehoseFactory, IngestSegmentFirehoseFactory, IrcFirehoseFactory, KafkaEightFirehoseFactory, LocalFirehoseFactory, RabbitMQFirehoseFactory, ReplayableFirehoseFactory, RocketMQFirehoseFactory, StaticAzureBlobStoreFirehoseFactory, StaticCloudFilesFirehoseFactory, StaticGoogleBlobStoreFirehoseFactory, StaticS3FirehoseFactory, TimedShutoffFirehoseFactory, TwitterSpritzerFirehoseFactory

public interface FirehoseFactory<T extends InputRowParser>

Method Summary

Modifier and Type	Method and Description
Firehose	connect(T parser) Initialization method that connects up the fire hose.

Method Detail

connect

Firehose connect(T parser)
          throws IOException,
                 ParseException

Initialization method that connects up the fire hose. If this method returns successfully it should be safe to call hasMore() on the returned Firehose (which might subsequently block).

If this method returns null, then any attempt to call hasMore(), nextRow(), commit() and close() on the return value will throw a surprising NPE. Throwing IOException on connection failure or runtime exception on invalid configuration is preferred over returning null.

Throws:

IOException

ParseException