io.druid.data.input

Class AvroStreamInputRowParser

java.lang.Object

io.druid.data.input.AvroStreamInputRowParser

All Implemented Interfaces:

io.druid.data.input.ByteBufferInputRowParser, io.druid.data.input.impl.InputRowParser<ByteBuffer>

public class AvroStreamInputRowParser
extends Object
implements io.druid.data.input.ByteBufferInputRowParser

Constructor Summary

Constructors

Constructor and Description
AvroStreamInputRowParser(io.druid.data.input.impl.ParseSpec parseSpec, AvroBytesDecoder avroBytesDecoder)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

AvroStreamInputRowParser

public AvroStreamInputRowParser(io.druid.data.input.impl.ParseSpec parseSpec,
                                AvroBytesDecoder avroBytesDecoder)

Method Detail

parse

public io.druid.data.input.InputRow parse(ByteBuffer input)

Specified by:

parse in interface io.druid.data.input.impl.InputRowParser<ByteBuffer>

parseGenericRecord

protected static io.druid.data.input.InputRow parseGenericRecord(org.apache.avro.generic.GenericRecord record,
                                                                 io.druid.data.input.impl.ParseSpec parseSpec,
                                                                 List<String> dimensions,
                                                                 boolean fromPigAvroStorage)

getParseSpec

public io.druid.data.input.impl.ParseSpec getParseSpec()

Specified by:

getParseSpec in interface io.druid.data.input.impl.InputRowParser<ByteBuffer>

getAvroBytesDecoder

public AvroBytesDecoder getAvroBytesDecoder()

withParseSpec

public io.druid.data.input.ByteBufferInputRowParser withParseSpec(io.druid.data.input.impl.ParseSpec parseSpec)

Specified by:

withParseSpec in interface io.druid.data.input.ByteBufferInputRowParser

Specified by:

withParseSpec in interface io.druid.data.input.impl.InputRowParser<ByteBuffer>

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object