public class AvroBytesConsumer extends BaseAvroConsumer<VarBinaryVector>
VarBinaryVector
.currentIndex, vector
Constructor and Description |
---|
AvroBytesConsumer(VarBinaryVector vector)
Instantiate a AvroBytesConsumer.
|
Modifier and Type | Method and Description |
---|---|
void |
consume(org.apache.avro.io.Decoder decoder)
Consume a specific type value from avro decoder and write it to vector.
|
addNull, close, getVector, resetValueVector, setPosition
public AvroBytesConsumer(VarBinaryVector vector)
public void consume(org.apache.avro.io.Decoder decoder) throws IOException
Consumer
decoder
- avro decoder to read dataIOException
- on errorCopyright © 2023 The Apache Software Foundation. All rights reserved.