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.data.input.impl.prefetch
io.druid.examples.twitter
io.druid.firehose.kafka
io.druid.firehose.rabbitmq
io.druid.firehose.rocketmq
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
default Firehose	FirehoseFactory.connect(T parser) Deprecated.
default Firehose	FirehoseFactory.connect(T parser, File temporaryDirectory) 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

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

Modifier and Type	Method and Description
Firehose	AbstractTextFilesFirehoseFactory.connect(StringInputRowParser firehoseParser, File temporaryDirectory)

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

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

Modifier and Type	Method and Description
Firehose	PrefetchableTextFilesFirehoseFactory.connect(StringInputRowParser firehoseParser, File temporaryDirectory)

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, File temporaryDirectory)

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(InputRowParser<ByteBuffer> firehoseParser, File temporaryDirectory)

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(InputRowParser<ByteBuffer> firehoseParser, File temporaryDirectory)

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(InputRowParser<ByteBuffer> byteBufferInputRowParser, File temporaryDirectory)

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, File temporaryDirectory)

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	EventReceiverFirehoseFactory.EventReceiverFirehose
class	IngestSegmentFirehose
class	PredicateFirehose Provides a view on a firehose that only returns rows that match a certain predicate.

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

Modifier and Type	Method and Description
Firehose	EventReceiverFirehoseFactory.connect(InputRowParser<Map<String,Object>> firehoseParser, File temporaryDirectory)
Firehose	IrcFirehoseFactory.connect(InputRowParser<Pair<org.joda.time.DateTime,com.ircclouds.irc.api.domain.messages.ChannelPrivMsg>> firehoseParser, File temporaryDirectory)
Firehose	TimedShutoffFirehoseFactory.connect(InputRowParser parser, File temporaryDirectory)
Firehose	FixedCountFirehoseFactory.connect(InputRowParser parser, File temporaryDirectory)
Firehose	CombiningFirehoseFactory.connect(InputRowParser parser, File temporaryDirectory)
Firehose	ClippedFirehoseFactory.connect(InputRowParser parser, File temporaryDirectory)

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)