Uses of Interface
io.druid.data.input.FirehoseFactory

Packages that use FirehoseFactory

Package	Description
io.druid.data.input.impl
io.druid.data.input.impl.prefetch
io.druid.examples.twitter
io.druid.firehose.azure
io.druid.firehose.cloudfiles
io.druid.firehose.google
io.druid.firehose.kafka
io.druid.firehose.rabbitmq
io.druid.firehose.rocketmq
io.druid.firehose.s3
io.druid.indexing.common.task
io.druid.indexing.firehose
io.druid.segment.indexing
io.druid.segment.realtime.firehose

Uses of FirehoseFactory in io.druid.data.input.impl

Classes in io.druid.data.input.impl that implement FirehoseFactory

Modifier and Type	Class and Description
class	AbstractTextFilesFirehoseFactory<T> This is an abstract class for firehose factory for making firehoses reading text files.

Uses of FirehoseFactory in io.druid.data.input.impl.prefetch

Classes in io.druid.data.input.impl.prefetch that implement FirehoseFactory

Modifier and Type	Class and Description
class	PrefetchableTextFilesFirehoseFactory<T> PrefetchableTextFilesFirehoseFactory is an abstract firehose factory for reading text files.

Uses of FirehoseFactory in io.druid.examples.twitter

Classes in io.druid.examples.twitter that implement FirehoseFactory

Modifier and Type	Class and Description
class	TwitterSpritzerFirehoseFactory Twitter "spritzer" Firehose Factory named "twitzer".

Uses of FirehoseFactory in io.druid.firehose.azure

Classes in io.druid.firehose.azure that implement FirehoseFactory

Modifier and Type	Class and Description
class	StaticAzureBlobStoreFirehoseFactory This class is heavily inspired by the StaticS3FirehoseFactory class in the io.druid.firehose.s3 package

Uses of FirehoseFactory in io.druid.firehose.cloudfiles

Classes in io.druid.firehose.cloudfiles that implement FirehoseFactory

Modifier and Type	Class and Description
class	StaticCloudFilesFirehoseFactory

Uses of FirehoseFactory in io.druid.firehose.google

Classes in io.druid.firehose.google that implement FirehoseFactory

Modifier and Type	Class and Description
class	StaticGoogleBlobStoreFirehoseFactory

Uses of FirehoseFactory in io.druid.firehose.kafka

Classes in io.druid.firehose.kafka that implement FirehoseFactory

Modifier and Type	Class and Description
class	KafkaEightFirehoseFactory

Uses of FirehoseFactory in io.druid.firehose.rabbitmq

Classes in io.druid.firehose.rabbitmq that implement FirehoseFactory

Modifier and Type	Class and Description
class	RabbitMQFirehoseFactory A FirehoseFactory for RabbitMQ.

Uses of FirehoseFactory in io.druid.firehose.rocketmq

Classes in io.druid.firehose.rocketmq that implement FirehoseFactory

Modifier and Type	Class and Description
class	RocketMQFirehoseFactory

Uses of FirehoseFactory in io.druid.firehose.s3

Classes in io.druid.firehose.s3 that implement FirehoseFactory

Modifier and Type	Class and Description
class	StaticS3FirehoseFactory Builds firehoses that read from a predefined list of S3 objects and then dry up.

Uses of FirehoseFactory in io.druid.indexing.common.task

Methods in io.druid.indexing.common.task that return FirehoseFactory

Modifier and Type	Method and Description
FirehoseFactory	NoopTask.getFirehoseFactory()
FirehoseFactory	IndexTask.IndexIOConfig.getFirehoseFactory()

Methods in io.druid.indexing.common.task with parameters of type FirehoseFactory

Modifier and Type	Method and Description
protected boolean	RealtimeIndexTask.isFirehoseDrainableByClosing(FirehoseFactory firehoseFactory) Is a firehose from this factory drainable by closing it? If so, we should drain on stopGracefully rather than abruptly stopping.

Constructors in io.druid.indexing.common.task with parameters of type FirehoseFactory

Constructor and Description
IndexIOConfig(FirehoseFactory firehoseFactory, Boolean appendToExisting)
NoopTask(String id, String dataSource, long runTime, long isReadyTime, String isReadyResult, FirehoseFactory firehoseFactory, Map<String,Object> context)

Uses of FirehoseFactory in io.druid.indexing.firehose

Classes in io.druid.indexing.firehose that implement FirehoseFactory

Modifier and Type	Class and Description
class	IngestSegmentFirehoseFactory

Uses of FirehoseFactory in io.druid.segment.indexing

Methods in io.druid.segment.indexing that return FirehoseFactory

Modifier and Type	Method and Description
FirehoseFactory	RealtimeIOConfig.getFirehoseFactory()

Constructors in io.druid.segment.indexing with parameters of type FirehoseFactory

Constructor and Description
RealtimeIOConfig(FirehoseFactory firehoseFactory, PlumberSchool plumberSchool, FirehoseFactoryV2 firehoseFactoryV2)

Uses of FirehoseFactory in io.druid.segment.realtime.firehose

Classes in io.druid.segment.realtime.firehose that implement FirehoseFactory

Modifier and Type	Class and Description
class	ClippedFirehoseFactory Creates firehoses clipped to a particular time interval.
class	CombiningFirehoseFactory Creates firehose that combines data from different Firehoses.
class	EventReceiverFirehoseFactory Builds firehoses that accept events through the EventReceiver interface.
class	FixedCountFirehoseFactory Firehose to give out only first n events from the delegate firehose.
class	HttpFirehoseFactory
class	IrcFirehoseFactory Example code:
class	LocalFirehoseFactory
class	TimedShutoffFirehoseFactory Creates firehoses that shut off at a particular time.

Methods in io.druid.segment.realtime.firehose that return FirehoseFactory

Modifier and Type	Method and Description
FirehoseFactory	FixedCountFirehoseFactory.getDelegate()
FirehoseFactory	ClippedFirehoseFactory.getDelegate()
FirehoseFactory	TimedShutoffFirehoseFactory.getDelegateFactory()

Methods in io.druid.segment.realtime.firehose that return types with arguments of type FirehoseFactory

Modifier and Type	Method and Description
List<FirehoseFactory>	CombiningFirehoseFactory.getDelegateFactoryList()

Constructors in io.druid.segment.realtime.firehose with parameters of type FirehoseFactory

Constructor and Description
ClippedFirehoseFactory(FirehoseFactory delegate, org.joda.time.Interval interval)
FixedCountFirehoseFactory(FirehoseFactory delegate, int count)
TimedShutoffFirehoseFactory(FirehoseFactory delegateFactory, org.joda.time.DateTime shutoffTime)

Constructor parameters in io.druid.segment.realtime.firehose with type arguments of type FirehoseFactory

Constructor and Description
CombiningFirehoseFactory(List<FirehoseFactory> delegateFactoryList)