org.apache.druid.segment.realtime.firehose

Class TimedShutoffFirehoseFactory

java.lang.Object

org.apache.druid.segment.realtime.firehose.TimedShutoffFirehoseFactory

All Implemented Interfaces:

org.apache.druid.data.input.FirehoseFactory<org.apache.druid.data.input.impl.InputRowParser>

public class TimedShutoffFirehoseFactory
extends Object
implements org.apache.druid.data.input.FirehoseFactory<org.apache.druid.data.input.impl.InputRowParser>

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

Constructor Summary

Constructors

Constructor and Description
TimedShutoffFirehoseFactory(org.apache.druid.data.input.FirehoseFactory delegateFactory, org.joda.time.DateTime shutoffTime)

Method Summary

Modifier and Type	Method and Description
org.apache.druid.data.input.Firehose	connect(org.apache.druid.data.input.impl.InputRowParser parser, File temporaryDirectory)
org.apache.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

Methods inherited from interface org.apache.druid.data.input.FirehoseFactory

connect, isSplittable

Constructor Detail

TimedShutoffFirehoseFactory

public TimedShutoffFirehoseFactory(org.apache.druid.data.input.FirehoseFactory delegateFactory,
                                   org.joda.time.DateTime shutoffTime)

Method Detail

connect

public org.apache.druid.data.input.Firehose connect(org.apache.druid.data.input.impl.InputRowParser parser,
                                                    File temporaryDirectory)
                                             throws IOException

Specified by:

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

Throws:

IOException

getDelegateFactory

public org.apache.druid.data.input.FirehoseFactory getDelegateFactory()

getShutoffTime

public org.joda.time.DateTime getShutoffTime()