T
- The vector within consumer or its delegate, used for partially consume purpose.public interface Consumer<T extends FieldVector> extends AutoCloseable
Modifier and Type | Method and Description |
---|---|
void |
addNull()
Add null value to vector by making writer position + 1.
|
void |
close()
Close this consumer when occurs exception to avoid potential leak.
|
void |
consume(org.apache.avro.io.Decoder decoder)
Consume a specific type value from avro decoder and write it to vector.
|
FieldVector |
getVector()
Get the vector within the consumer.
|
boolean |
resetValueVector(T vector)
Reset the vector within consumer for partial read purpose.
|
void |
setPosition(int index)
Set the position to write value into vector.
|
default boolean |
skippable()
Indicates whether the consumer is type of
SkipConsumer . |
void consume(org.apache.avro.io.Decoder decoder) throws IOException
decoder
- avro decoder to read dataIOException
- on errorvoid addNull()
void setPosition(int index)
FieldVector getVector()
void close() throws Exception
close
in interface AutoCloseable
Exception
boolean resetValueVector(T vector)
default boolean skippable()
SkipConsumer
.Copyright © 2023 The Apache Software Foundation. All rights reserved.