public class AvroStreamInputRowParser extends Object implements io.druid.data.input.ByteBufferInputRowParser
Constructor and Description |
---|
AvroStreamInputRowParser(io.druid.data.input.impl.ParseSpec parseSpec,
AvroBytesDecoder avroBytesDecoder) |
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) |
public AvroStreamInputRowParser(io.druid.data.input.impl.ParseSpec parseSpec, AvroBytesDecoder avroBytesDecoder)
public io.druid.data.input.InputRow parse(ByteBuffer input)
parse
in interface io.druid.data.input.impl.InputRowParser<ByteBuffer>
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)
public io.druid.data.input.impl.ParseSpec getParseSpec()
getParseSpec
in interface io.druid.data.input.impl.InputRowParser<ByteBuffer>
public AvroBytesDecoder getAvroBytesDecoder()
public io.druid.data.input.ByteBufferInputRowParser withParseSpec(io.druid.data.input.impl.ParseSpec parseSpec)
withParseSpec
in interface io.druid.data.input.ByteBufferInputRowParser
withParseSpec
in interface io.druid.data.input.impl.InputRowParser<ByteBuffer>
Copyright © 2011–2016. All rights reserved.