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.
|
Modifier and Type | Class and Description |
---|---|
class |
FileIteratingFirehose |
Modifier and Type | Method and Description |
---|---|
Firehose |
AbstractTextFilesFirehoseFactory.connect(StringInputRowParser firehoseParser,
File temporaryDirectory) |
Modifier and Type | Method and Description |
---|---|
Firehose |
PrefetchableTextFilesFirehoseFactory.connect(StringInputRowParser firehoseParser,
File temporaryDirectory) |
Modifier and Type | Method and Description |
---|---|
Firehose |
TwitterSpritzerFirehoseFactory.connect(InputRowParser parser,
File temporaryDirectory) |
Modifier and Type | Method and Description |
---|---|
Firehose |
KafkaEightFirehoseFactory.connect(InputRowParser<ByteBuffer> firehoseParser,
File temporaryDirectory) |
Modifier and Type | Method and Description |
---|---|
Firehose |
RabbitMQFirehoseFactory.connect(InputRowParser<ByteBuffer> firehoseParser,
File temporaryDirectory) |
Modifier and Type | Method and Description |
---|---|
Firehose |
RocketMQFirehoseFactory.connect(InputRowParser<ByteBuffer> byteBufferInputRowParser,
File temporaryDirectory) |
Modifier and Type | Method and Description |
---|---|
Firehose |
RealtimeIndexTask.getFirehose()
Public for tests.
|
Modifier and Type | Method and Description |
---|---|
Firehose |
IngestSegmentFirehoseFactory.connect(InputRowParser inputRowParser,
File temporaryDirectory) |
Modifier and Type | Method and Description |
---|---|
Firehose |
FireDepartment.connect() |
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.
|
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) |
Constructor and Description |
---|
PredicateFirehose(Firehose firehose,
com.google.common.base.Predicate<InputRow> predicate) |
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) |
Copyright © 2011–2018. All rights reserved.