io.druid.segment.realtime.firehose

Class FixedCountFirehoseFactory

java.lang.Object

io.druid.segment.realtime.firehose.FixedCountFirehoseFactory

All Implemented Interfaces:

FirehoseFactory

public class FixedCountFirehoseFactory
extends Object
implements FirehoseFactory

Firehose to give out only first n events from the delegate firehose.

Constructor Summary

Constructors

Constructor and Description
FixedCountFirehoseFactory(FirehoseFactory delegate, int count)

Method Summary

Modifier and Type	Method and Description
Firehose	connect(InputRowParser parser) Initialization method that connects up the fire hose.
int	getCount()
FirehoseFactory	getDelegate()

Methods inherited from class java.lang.Object

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

Constructor Detail

FixedCountFirehoseFactory

public FixedCountFirehoseFactory(FirehoseFactory delegate,
                                 int count)

Method Detail

getDelegate

public FirehoseFactory getDelegate()

getCount

public int getCount()

connect

public Firehose connect(InputRowParser parser)
                 throws IOException

Description copied from interface: FirehoseFactory

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.

Specified by:

connect in interface FirehoseFactory

Throws:

IOException