Modifier and Type | Interface and Description |
---|---|
interface |
FirehoseFactory<T extends InputRowParser> |
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 |
class |
ProtoBufInputRowParser |
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 |
ThriftInputRowParser
1.
|
Modifier and Type | Method and Description |
---|---|
InputRowParser |
ThriftInputRowParser.withParseSpec(ParseSpec parseSpec) |
Modifier and Type | Method and Description |
---|---|
Firehose |
TwitterSpritzerFirehoseFactory.connect(InputRowParser parser) |
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) |
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) |
Firehose |
ReplayableFirehoseFactory.connect(InputRowParser parser) |
Firehose |
FixedCountFirehoseFactory.connect(InputRowParser parser) |
Firehose |
CombiningFirehoseFactory.connect(InputRowParser parser) |
Firehose |
ClippedFirehoseFactory.connect(InputRowParser parser) |
Constructor and Description |
---|
CombiningFirehose(InputRowParser parser) |
ReplayableFirehose(InputRowParser parser) |
TimedShutoffFirehose(InputRowParser parser) |
Copyright © 2011–2017. All rights reserved.