io.druid.segment.realtime.firehose

Class TimedShutoffFirehoseFactory

java.lang.Object

io.druid.segment.realtime.firehose.TimedShutoffFirehoseFactory

All Implemented Interfaces:

io.druid.data.input.FirehoseFactory<io.druid.data.input.impl.InputRowParser>

public class TimedShutoffFirehoseFactory
extends Object
implements io.druid.data.input.FirehoseFactory<io.druid.data.input.impl.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(io.druid.data.input.FirehoseFactory delegateFactory, org.joda.time.DateTime shutoffTime)

Method Summary

Methods

Modifier and Type	Method and Description
io.druid.data.input.Firehose	connect(io.druid.data.input.impl.InputRowParser parser)
io.druid.data.input.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(io.druid.data.input.FirehoseFactory delegateFactory,
                           org.joda.time.DateTime shutoffTime)

Method Detail

connect

public io.druid.data.input.Firehose connect(io.druid.data.input.impl.InputRowParser parser)
                                     throws IOException

Specified by:

connect in interface io.druid.data.input.FirehoseFactory<io.druid.data.input.impl.InputRowParser>

Throws:

IOException

getDelegateFactory

public io.druid.data.input.FirehoseFactory getDelegateFactory()

getShutoffTime

public org.joda.time.DateTime getShutoffTime()