io.druid.data.input

Interface FirehoseFactoryV2<T extends InputRowParser>

All Known Implementing Classes:

KafkaEightSimpleConsumerFirehoseFactory

public interface FirehoseFactoryV2<T extends InputRowParser>

Initialization method that connects up the FirehoseV2. If this method returns successfully it should be safe to call start() on the returned FirehoseV2 (which might subsequently block). In contrast to V1 version, FirehoseFactoryV2 is able to pass an additional json-serialized object to FirehoseV2, which contains last commit metadata

If this method returns null, then any attempt to call start(), advance(), currRow(), makeCommitter() 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.

Method Summary

Modifier and Type	Method and Description
FirehoseV2	connect(T parser, Object lastCommit)

Method Detail

connect

FirehoseV2 connect(T parser,
                   Object lastCommit)
            throws IOException,
                   ParseException

Throws:

IOException

ParseException