| Modifier and Type | Interface and Description | 
|---|---|
interface  | 
FirehoseFactory<T extends InputRowParser>
FirehoseFactory creates a  
Firehose which is an interface holding onto the stream of incoming data. | 
interface  | 
FirehoseFactoryV2<T extends InputRowParser>
Initialization method that connects up the FirehoseV2. 
 | 
| Modifier and Type | Interface and Description | 
|---|---|
interface  | 
ByteBufferInputRowParser  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
AvroHadoopInputRowParser  | 
class  | 
AvroStreamInputRowParser  | 
| Modifier and Type | Method and Description | 
|---|---|
InputRowParser | 
AvroHadoopInputRowParser.withParseSpec(ParseSpec parseSpec)  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
MapInputRowParser  | 
class  | 
NoopInputRowParser  | 
class  | 
StringInputRowParser  | 
| Modifier and Type | Method and Description | 
|---|---|
InputRowParser | 
NoopInputRowParser.withParseSpec(ParseSpec parseSpec)  | 
InputRowParser | 
MapInputRowParser.withParseSpec(ParseSpec parseSpec)  | 
InputRowParser | 
InputRowParser.withParseSpec(ParseSpec parseSpec)  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
OrcHadoopInputRowParser  | 
| Modifier and Type | Method and Description | 
|---|---|
InputRowParser | 
OrcHadoopInputRowParser.withParseSpec(ParseSpec parseSpec)  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
ParquetHadoopInputRowParser  | 
| Modifier and Type | Method and Description | 
|---|---|
InputRowParser | 
ParquetHadoopInputRowParser.withParseSpec(ParseSpec parseSpec)  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
ProtobufInputRowParser  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
ThriftInputRowParser
1. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
InputRowParser | 
ThriftInputRowParser.withParseSpec(ParseSpec parseSpec)  | 
| 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 | Class and Description | 
|---|---|
class  | 
HadoopyStringInputRowParser  | 
| Modifier and Type | Method and Description | 
|---|---|
InputRowParser | 
HadoopDruidIndexerConfig.getParser()  | 
InputRowParser | 
HadoopyStringInputRowParser.withParseSpec(ParseSpec parseSpec)  | 
| Modifier and Type | Method and Description | 
|---|---|
Firehose | 
IngestSegmentFirehoseFactory.connect(InputRowParser inputRowParser,
       File temporaryDirectory)  | 
| Modifier and Type | Method and Description | 
|---|---|
IncrementalIndexSchema.Builder | 
IncrementalIndexSchema.Builder.withDimensionsSpec(InputRowParser parser)  | 
IncrementalIndexSchema.Builder | 
IncrementalIndexSchema.Builder.withTimestampSpec(InputRowParser parser)  | 
| Modifier and Type | Method and Description | 
|---|---|
InputRowParser | 
DataSchema.getParser()  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
IrcInputRowParser
Example Usage 
 | 
| Modifier and Type | Method and Description | 
|---|---|
InputRowParser | 
IrcInputRowParser.withParseSpec(ParseSpec parseSpec)  | 
| 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 | 
|---|
EventReceiverFirehose(InputRowParser<Map<String,Object>> parser)  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
TransformingInputRowParser<T>  | 
class  | 
TransformingStringInputRowParser  | 
| Modifier and Type | Method and Description | 
|---|---|
<T> InputRowParser<T> | 
TransformSpec.decorate(InputRowParser<T> parser)  | 
InputRowParser<T> | 
TransformingInputRowParser.getParser()  | 
InputRowParser<T> | 
TransformingInputRowParser.withParseSpec(ParseSpec parseSpec)  | 
| Modifier and Type | Method and Description | 
|---|---|
<T> InputRowParser<T> | 
TransformSpec.decorate(InputRowParser<T> parser)  | 
static <T> TransformSpec | 
TransformSpec.fromInputRowParser(InputRowParser<T> parser)  | 
| Constructor and Description | 
|---|
TransformingInputRowParser(InputRowParser<T> parser,
                          TransformSpec transformSpec)  | 
Copyright © 2011–2018. All rights reserved.