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

Packages that use Firehose

Package	Description
io.druid.data.input
io.druid.data.input.impl
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.realtime
io.druid.segment.realtime.firehose
io.druid.segment.realtime.plumber

Uses of Firehose in io.druid.data.input

Methods in io.druid.data.input that return Firehose

Modifier and Type	Method and Description
Firehose	FirehoseFactory.connect(T parser) Initialization method that connects up the fire hose.

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

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

Modifier and Type	Class and Description
class	FileIteratingFirehose

Uses of Firehose in io.druid.examples.twitter

Methods in io.druid.examples.twitter that return Firehose

Modifier and Type	Method and Description
Firehose	TwitterSpritzerFirehoseFactory.connect(InputRowParser parser)

Uses of Firehose in io.druid.firehose.azure

Methods in io.druid.firehose.azure that return Firehose

Modifier and Type	Method and Description
Firehose	StaticAzureBlobStoreFirehoseFactory.connect(StringInputRowParser stringInputRowParser)

Uses of Firehose in io.druid.firehose.cloudfiles

Methods in io.druid.firehose.cloudfiles that return Firehose

Modifier and Type	Method and Description
Firehose	StaticCloudFilesFirehoseFactory.connect(StringInputRowParser stringInputRowParser)

Uses of Firehose in io.druid.firehose.google

Methods in io.druid.firehose.google that return Firehose

Modifier and Type	Method and Description
Firehose	StaticGoogleBlobStoreFirehoseFactory.connect(StringInputRowParser stringInputRowParser)

Uses of Firehose in io.druid.firehose.kafka

Methods in io.druid.firehose.kafka that return Firehose

Modifier and Type	Method and Description
Firehose	KafkaEightFirehoseFactory.connect(ByteBufferInputRowParser firehoseParser)

Uses of Firehose in io.druid.firehose.rabbitmq

Methods in io.druid.firehose.rabbitmq that return Firehose

Modifier and Type	Method and Description
Firehose	RabbitMQFirehoseFactory.connect(ByteBufferInputRowParser firehoseParser)

Uses of Firehose in io.druid.firehose.rocketmq

Methods in io.druid.firehose.rocketmq that return Firehose

Modifier and Type	Method and Description
Firehose	RocketMQFirehoseFactory.connect(ByteBufferInputRowParser byteBufferInputRowParser)

Uses of Firehose in io.druid.firehose.s3

Methods in io.druid.firehose.s3 that return Firehose

Modifier and Type	Method and Description
Firehose	StaticS3FirehoseFactory.connect(StringInputRowParser firehoseParser)

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

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

Modifier and Type	Method and Description
Firehose	RealtimeIndexTask.getFirehose() Public for tests.

Uses of Firehose in io.druid.indexing.firehose

Methods in io.druid.indexing.firehose that return Firehose

Modifier and Type	Method and Description
Firehose	IngestSegmentFirehoseFactory.connect(InputRowParser inputRowParser)

Uses of Firehose in io.druid.segment.realtime

Methods in io.druid.segment.realtime that return Firehose

Modifier and Type	Method and Description
Firehose	FireDepartment.connect()

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

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

Modifier and Type	Class and Description
class	CombiningFirehoseFactory.CombiningFirehose
class	EventReceiverFirehoseFactory.EventReceiverFirehose
class	IngestSegmentFirehose
class	PredicateFirehose Provides a view on a firehose that only returns rows that match a certain predicate.
class	ReplayableFirehoseFactory.ReplayableFirehose
class	TimedShutoffFirehoseFactory.TimedShutoffFirehose

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

Modifier and Type	Method and Description
Firehose	TimedShutoffFirehoseFactory.connect(InputRowParser parser)
Firehose	ReplayableFirehoseFactory.connect(InputRowParser parser)
Firehose	FixedCountFirehoseFactory.connect(InputRowParser parser)
Firehose	CombiningFirehoseFactory.connect(InputRowParser parser)
Firehose	ClippedFirehoseFactory.connect(InputRowParser parser)
Firehose	IrcFirehoseFactory.connect(IrcInputRowParser firehoseParser)
Firehose	EventReceiverFirehoseFactory.connect(MapInputRowParser firehoseParser)
Firehose	LocalFirehoseFactory.connect(StringInputRowParser firehoseParser)

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

Constructor and Description
PredicateFirehose(Firehose firehose, com.google.common.base.Predicate<InputRow> predicate)

Uses of Firehose in io.druid.segment.realtime.plumber

Methods in io.druid.segment.realtime.plumber with parameters of type Firehose

Modifier and Type	Method and Description
static void	Plumbers.addNextRow(com.google.common.base.Supplier<Committer> committerSupplier, Firehose firehose, Plumber plumber, boolean reportParseExceptions, FireDepartmentMetrics metrics)
static com.google.common.base.Supplier<Committer>	Committers.supplierFromFirehose(Firehose firehose)