io.druid.segment.realtime.firehose

Class ClippedFirehoseFactory

java.lang.Object

io.druid.segment.realtime.firehose.ClippedFirehoseFactory

All Implemented Interfaces:

io.druid.data.input.FirehoseFactory

public class ClippedFirehoseFactory
extends Object
implements io.druid.data.input.FirehoseFactory

Creates firehoses clipped to a particular time interval. Useful for enforcing min time, max time, and time windows.

Constructor Summary

Constructors

Constructor and Description
ClippedFirehoseFactory(io.druid.data.input.FirehoseFactory delegate, org.joda.time.Interval interval)

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	getDelegate()
org.joda.time.Interval	getInterval()

Methods inherited from class java.lang.Object

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

Constructor Detail

ClippedFirehoseFactory

public ClippedFirehoseFactory(io.druid.data.input.FirehoseFactory delegate,
                      org.joda.time.Interval interval)

Method Detail

getDelegate

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

getInterval

public org.joda.time.Interval getInterval()

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

Throws:

IOException