Package | Description |
---|---|
io.druid.data.input | |
io.druid.data.input.impl | |
io.druid.data.input.orc | |
io.druid.data.input.parquet | |
io.druid.data.input.thrift | |
io.druid.indexer | |
io.druid.segment.realtime.firehose |
Modifier and Type | Method and Description |
---|---|
ParseSpec |
AvroStreamInputRowParser.getParseSpec() |
ParseSpec |
AvroHadoopInputRowParser.getParseSpec() |
ParseSpec |
ProtoBufInputRowParser.getParseSpec() |
Modifier and Type | Method and Description |
---|---|
protected static InputRow |
AvroStreamInputRowParser.parseGenericRecord(org.apache.avro.generic.GenericRecord record,
ParseSpec parseSpec,
List<String> dimensions,
boolean fromPigAvroStorage,
boolean binaryAsString) |
ByteBufferInputRowParser |
AvroStreamInputRowParser.withParseSpec(ParseSpec parseSpec) |
InputRowParser |
AvroHadoopInputRowParser.withParseSpec(ParseSpec parseSpec) |
ByteBufferInputRowParser |
ByteBufferInputRowParser.withParseSpec(ParseSpec parseSpec) |
ProtoBufInputRowParser |
ProtoBufInputRowParser.withParseSpec(ParseSpec parseSpec) |
Constructor and Description |
---|
AvroHadoopInputRowParser(ParseSpec parseSpec,
Boolean fromPigAvroStorage) |
AvroStreamInputRowParser(ParseSpec parseSpec,
AvroBytesDecoder avroBytesDecoder) |
ProtoBufInputRowParser(ParseSpec parseSpec,
String descriptorFileInClasspath) |
Modifier and Type | Class and Description |
---|---|
class |
CSVParseSpec |
class |
DelimitedParseSpec |
class |
JavaScriptParseSpec |
class |
JSONLowercaseParseSpec
Deprecated.
|
class |
JSONParseSpec |
class |
RegexParseSpec |
class |
TimeAndDimsParseSpec |
Modifier and Type | Method and Description |
---|---|
StringInputRowParser |
StringInputRowParser.withParseSpec(ParseSpec parseSpec) |
InputRowParser |
NoopInputRowParser.withParseSpec(ParseSpec parseSpec) |
InputRowParser |
MapInputRowParser.withParseSpec(ParseSpec parseSpec) |
InputRowParser |
InputRowParser.withParseSpec(ParseSpec parseSpec) |
Constructor and Description |
---|
MapInputRowParser(ParseSpec parseSpec) |
NoopInputRowParser(ParseSpec parseSpec) |
StringInputRowParser(ParseSpec parseSpec)
Deprecated.
|
StringInputRowParser(ParseSpec parseSpec,
String encoding) |
Modifier and Type | Method and Description |
---|---|
ParseSpec |
OrcHadoopInputRowParser.getParseSpec() |
Modifier and Type | Method and Description |
---|---|
static String |
OrcHadoopInputRowParser.typeStringFromParseSpec(ParseSpec parseSpec) |
InputRowParser |
OrcHadoopInputRowParser.withParseSpec(ParseSpec parseSpec) |
Constructor and Description |
---|
OrcHadoopInputRowParser(ParseSpec parseSpec,
String typeString) |
Modifier and Type | Method and Description |
---|---|
ParseSpec |
ParquetHadoopInputRowParser.getParseSpec() |
Modifier and Type | Method and Description |
---|---|
InputRowParser |
ParquetHadoopInputRowParser.withParseSpec(ParseSpec parseSpec) |
Constructor and Description |
---|
ParquetHadoopInputRowParser(ParseSpec parseSpec,
Boolean binaryAsString) |
Modifier and Type | Method and Description |
---|---|
ParseSpec |
ThriftInputRowParser.getParseSpec() |
Modifier and Type | Method and Description |
---|---|
InputRowParser |
ThriftInputRowParser.withParseSpec(ParseSpec parseSpec) |
Constructor and Description |
---|
ThriftInputRowParser(ParseSpec parseSpec,
String jarPath,
String thriftClassName) |
Modifier and Type | Method and Description |
---|---|
ParseSpec |
HadoopyStringInputRowParser.getParseSpec() |
Modifier and Type | Method and Description |
---|---|
InputRowParser |
HadoopyStringInputRowParser.withParseSpec(ParseSpec parseSpec) |
Constructor and Description |
---|
HadoopyStringInputRowParser(ParseSpec parseSpec) |
Modifier and Type | Method and Description |
---|---|
ParseSpec |
IrcInputRowParser.getParseSpec() |
Modifier and Type | Method and Description |
---|---|
InputRowParser |
IrcInputRowParser.withParseSpec(ParseSpec parseSpec) |
Constructor and Description |
---|
IrcInputRowParser(ParseSpec parseSpec,
IrcDecoder decoder) |
Copyright © 2011–2017. All rights reserved.