Modifier and Type | Class and Description |
---|---|
class |
AbstractTextFilesFirehoseFactory<T>
This is an abstract class for firehose factory for making firehoses reading text files.
|
Modifier and Type | Class and Description |
---|---|
class |
PrefetchableTextFilesFirehoseFactory<T>
PrefetchableTextFilesFirehoseFactory is an abstract firehose factory for reading text files.
|
Modifier and Type | Class and Description |
---|---|
class |
TwitterSpritzerFirehoseFactory
Twitter "spritzer" Firehose Factory named "twitzer".
|
Modifier and Type | Class and Description |
---|---|
class |
StaticAzureBlobStoreFirehoseFactory
This class is heavily inspired by the StaticS3FirehoseFactory class in the io.druid.firehose.s3 package
|
Modifier and Type | Class and Description |
---|---|
class |
StaticCloudFilesFirehoseFactory |
Modifier and Type | Class and Description |
---|---|
class |
StaticGoogleBlobStoreFirehoseFactory |
Modifier and Type | Class and Description |
---|---|
class |
KafkaEightFirehoseFactory |
Modifier and Type | Class and Description |
---|---|
class |
RabbitMQFirehoseFactory
A FirehoseFactory for RabbitMQ.
|
Modifier and Type | Class and Description |
---|---|
class |
RocketMQFirehoseFactory |
Modifier and Type | Class and Description |
---|---|
class |
StaticS3FirehoseFactory
Builds firehoses that read from a predefined list of S3 objects and then dry up.
|
Modifier and Type | Method and Description |
---|---|
FirehoseFactory |
NoopTask.getFirehoseFactory() |
FirehoseFactory |
IndexTask.IndexIOConfig.getFirehoseFactory() |
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.
|
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) |
Modifier and Type | Class and Description |
---|---|
class |
IngestSegmentFirehoseFactory |
Modifier and Type | Method and Description |
---|---|
FirehoseFactory |
RealtimeIOConfig.getFirehoseFactory() |
Constructor and Description |
---|
RealtimeIOConfig(FirehoseFactory firehoseFactory,
PlumberSchool plumberSchool,
FirehoseFactoryV2 firehoseFactoryV2) |
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.
|
Modifier and Type | Method and Description |
---|---|
FirehoseFactory |
FixedCountFirehoseFactory.getDelegate() |
FirehoseFactory |
ClippedFirehoseFactory.getDelegate() |
FirehoseFactory |
TimedShutoffFirehoseFactory.getDelegateFactory() |
Modifier and Type | Method and Description |
---|---|
List<FirehoseFactory> |
CombiningFirehoseFactory.getDelegateFactoryList() |
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 and Description |
---|
CombiningFirehoseFactory(List<FirehoseFactory> delegateFactoryList) |
Copyright © 2011–2018. All rights reserved.