io.druid.data.input.parquet

Class ParquetHadoopInputRowParser

java.lang.Object

io.druid.data.input.parquet.ParquetHadoopInputRowParser

All Implemented Interfaces:

InputRowParser<org.apache.avro.generic.GenericRecord>

public class ParquetHadoopInputRowParser
extends Object
implements InputRowParser<org.apache.avro.generic.GenericRecord>

Constructor Summary

Constructors

Constructor and Description
ParquetHadoopInputRowParser(ParseSpec parseSpec, Boolean binaryAsString)

Method Summary

Modifier and Type	Method and Description
ParseSpec	getParseSpec()
InputRow	parse(org.apache.avro.generic.GenericRecord record) imitate avro extension AvroStreamInputRowParser.parseGenericRecord(GenericRecord, ParseSpec, List, boolean, boolean)
InputRowParser	withParseSpec(ParseSpec parseSpec)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ParquetHadoopInputRowParser

public ParquetHadoopInputRowParser(ParseSpec parseSpec,
                                   Boolean binaryAsString)

Method Detail

parse

public InputRow parse(org.apache.avro.generic.GenericRecord record)

imitate avro extension AvroStreamInputRowParser.parseGenericRecord(GenericRecord, ParseSpec, List, boolean, boolean)

Specified by:

parse in interface InputRowParser<org.apache.avro.generic.GenericRecord>

getParseSpec

public ParseSpec getParseSpec()

Specified by:

getParseSpec in interface InputRowParser<org.apache.avro.generic.GenericRecord>

withParseSpec

public InputRowParser withParseSpec(ParseSpec parseSpec)

Specified by:

withParseSpec in interface InputRowParser<org.apache.avro.generic.GenericRecord>