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.