Module org.apache.arrow.adapter.avro
Package org.apache.arrow.adapter.avro.consumers

Class AvroNullableConsumer<T extends FieldVector>

java.lang.Object
org.apache.arrow.adapter.avro.consumers.BaseAvroConsumer<T>
org.apache.arrow.adapter.avro.consumers.AvroNullableConsumer<T>
Type Parameters:
T - The vector within consumer or its delegate.
All Implemented Interfaces:
AutoCloseable, Consumer<T>
public class AvroNullableConsumer<T extends FieldVector> extends BaseAvroConsumer<T>
Consumer wrapper which consumes nullable type values from avro decoder. Write the data to the underlying FieldVector.

  • Field Summary

    Fields inherited from class org.apache.arrow.adapter.avro.consumers.BaseAvroConsumer

    currentIndex, vector

  • Constructor Summary

    Constructors
    Constructor
    Description
    AvroNullableConsumer(Consumer<T> delegate, int nullIndex)
    Instantiate a AvroNullableConsumer.

  • Method Summary

    Modifier and Type
    Method
    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.
    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.

    Methods inherited from class org.apache.arrow.adapter.avro.consumers.BaseAvroConsumer

    getVector

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    Methods inherited from interface org.apache.arrow.adapter.avro.consumers.Consumer

    skippable