org.apache.druid.segment.realtime.firehose

Class FixedCountFirehoseFactory

java.lang.Object

org.apache.druid.segment.realtime.firehose.FixedCountFirehoseFactory

All Implemented Interfaces:

org.apache.druid.data.input.FirehoseFactory

public class FixedCountFirehoseFactory
extends Object
implements org.apache.druid.data.input.FirehoseFactory

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

Constructor Summary

Constructors

Constructor and Description
FixedCountFirehoseFactory(org.apache.druid.data.input.FirehoseFactory delegate, int count)

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)
int	getCount()
org.apache.druid.data.input.FirehoseFactory	getDelegate()

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

FixedCountFirehoseFactory

public FixedCountFirehoseFactory(org.apache.druid.data.input.FirehoseFactory delegate,
                                 int count)

Method Detail

getDelegate

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

getCount

public int getCount()

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

Throws:

IOException