io.druid.segment.realtime.firehose

Class TimedShutoffFirehoseFactory

java.lang.Object

io.druid.segment.realtime.firehose.TimedShutoffFirehoseFactory

All Implemented Interfaces:

FirehoseFactory<InputRowParser>

public class TimedShutoffFirehoseFactory
extends Object
implements FirehoseFactory<InputRowParser>

Creates firehoses that shut off at a particular time. Useful for limiting the lifespan of a realtime job.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	TimedShutoffFirehoseFactory.TimedShutoffFirehose

Constructor Summary

Constructors

Constructor and Description
TimedShutoffFirehoseFactory(FirehoseFactory delegateFactory, org.joda.time.DateTime shutoffTime)

Method Summary

Modifier and Type	Method and Description
Firehose	connect(InputRowParser parser) Initialization method that connects up the fire hose.
FirehoseFactory	getDelegateFactory()
org.joda.time.DateTime	getShutoffTime()

Methods inherited from class java.lang.Object

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

Constructor Detail

TimedShutoffFirehoseFactory

public TimedShutoffFirehoseFactory(FirehoseFactory delegateFactory,
                                   org.joda.time.DateTime shutoffTime)

Method Detail

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<InputRowParser>

Throws:

IOException

getDelegateFactory

public FirehoseFactory getDelegateFactory()

getShutoffTime

public org.joda.time.DateTime getShutoffTime()