public class AvroStreamInputRowParser extends Object implements org.apache.druid.data.input.ByteBufferInputRowParser
Constructor and Description |
---|
AvroStreamInputRowParser(org.apache.druid.data.input.impl.ParseSpec parseSpec,
AvroBytesDecoder avroBytesDecoder) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object o) |
AvroBytesDecoder |
getAvroBytesDecoder() |
org.apache.druid.data.input.impl.ParseSpec |
getParseSpec() |
int |
hashCode() |
List<org.apache.druid.data.input.InputRow> |
parseBatch(ByteBuffer input) |
org.apache.druid.data.input.ByteBufferInputRowParser |
withParseSpec(org.apache.druid.data.input.impl.ParseSpec parseSpec) |
public AvroStreamInputRowParser(org.apache.druid.data.input.impl.ParseSpec parseSpec, AvroBytesDecoder avroBytesDecoder)
@NotNull public List<org.apache.druid.data.input.InputRow> parseBatch(ByteBuffer input)
parseBatch
in interface org.apache.druid.data.input.impl.InputRowParser<ByteBuffer>
public org.apache.druid.data.input.impl.ParseSpec getParseSpec()
getParseSpec
in interface org.apache.druid.data.input.impl.InputRowParser<ByteBuffer>
public AvroBytesDecoder getAvroBytesDecoder()
public org.apache.druid.data.input.ByteBufferInputRowParser withParseSpec(org.apache.druid.data.input.impl.ParseSpec parseSpec)
withParseSpec
in interface org.apache.druid.data.input.ByteBufferInputRowParser
withParseSpec
in interface org.apache.druid.data.input.impl.InputRowParser<ByteBuffer>
Copyright © 2022 The Apache Software Foundation. All rights reserved.