io.druid.data.input

Class AvroStreamInputRowParser

java.lang.Object

io.druid.data.input.AvroStreamInputRowParser

All Implemented Interfaces:

ByteBufferInputRowParser, InputRowParser<ByteBuffer>

public class AvroStreamInputRowParser
extends Object
implements ByteBufferInputRowParser

Constructor Summary

Constructors

Constructor and Description
AvroStreamInputRowParser(ParseSpec parseSpec, AvroBytesDecoder avroBytesDecoder)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
AvroBytesDecoder	getAvroBytesDecoder()
ParseSpec	getParseSpec()
int	hashCode()
InputRow	parse(ByteBuffer input)
protected static InputRow	parseGenericRecord(org.apache.avro.generic.GenericRecord record, ParseSpec parseSpec, List<String> dimensions, boolean fromPigAvroStorage, boolean binaryAsString)
ByteBufferInputRowParser	withParseSpec(ParseSpec parseSpec)

Methods inherited from class java.lang.Object

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

Constructor Detail

AvroStreamInputRowParser

public AvroStreamInputRowParser(ParseSpec parseSpec,
                                AvroBytesDecoder avroBytesDecoder)

Method Detail

parse

public InputRow parse(ByteBuffer input)

Specified by:

parse in interface InputRowParser<ByteBuffer>

parseGenericRecord

protected static InputRow parseGenericRecord(org.apache.avro.generic.GenericRecord record,
                                             ParseSpec parseSpec,
                                             List<String> dimensions,
                                             boolean fromPigAvroStorage,
                                             boolean binaryAsString)

getParseSpec

public ParseSpec getParseSpec()

Specified by:

getParseSpec in interface InputRowParser<ByteBuffer>

getAvroBytesDecoder

public AvroBytesDecoder getAvroBytesDecoder()

withParseSpec

public ByteBufferInputRowParser withParseSpec(ParseSpec parseSpec)

Specified by:

withParseSpec in interface ByteBufferInputRowParser

Specified by:

withParseSpec in interface InputRowParser<ByteBuffer>

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object