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()
List<InputRow>	parseBatch(org.apache.avro.generic.GenericRecord record) imitate avro extension AvroParsers.parseGenericRecord(GenericRecord, ParseSpec, ObjectFlattener)
InputRowParser	withParseSpec(ParseSpec parseSpec)

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.druid.data.input.impl.InputRowParser

parse

Constructor Detail

ParquetHadoopInputRowParser

public ParquetHadoopInputRowParser(ParseSpec parseSpec,
                                   Boolean binaryAsString)

Method Detail

parseBatch

public List<InputRow> parseBatch(org.apache.avro.generic.GenericRecord record)

imitate avro extension AvroParsers.parseGenericRecord(GenericRecord, ParseSpec, ObjectFlattener)

Specified by:

parseBatch 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>