public class AvroStringConsumer extends BaseAvroConsumer<VarCharVector>
VarCharVector
.currentIndex, vector
Constructor and Description |
---|
AvroStringConsumer(VarCharVector vector)
Instantiate a AvroStringConsumer.
|
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 AvroStringConsumer(VarCharVector vector)
public void consume(org.apache.avro.io.Decoder decoder) throws IOException
Consumer
decoder
- avro decoder to read dataIOException
- on errorCopyright © 2024 The Apache Software Foundation. All rights reserved.