| 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) |
InputRowParser |
OrcHadoopInputRowParser.withTypeString(String typeString) |
| 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 | Class and Description |
|---|---|
class |
HadoopyStringInputRowParser |
| Modifier and Type | Method and Description |
|---|---|
InputRowParser |
HadoopDruidIndexerMapper.getParser() |
InputRowParser |
HadoopDruidIndexerConfig.getParser() |
InputRowParser |
HadoopyStringInputRowParser.withParseSpec(ParseSpec parseSpec) |
| Modifier and Type | Method and Description |
|---|---|
static InputRow |
HadoopDruidIndexerMapper.parseInputRow(Object value,
InputRowParser parser) |
| 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 |
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) |
Copyright © 2011–2017. All rights reserved.