org.apache.arrow.consumers

Class AvroUnionsConsumer

java.lang.Object

org.apache.arrow.consumers.BaseAvroConsumer<UnionVector>

org.apache.arrow.consumers.AvroUnionsConsumer

All Implemented Interfaces:

AutoCloseable, Consumer<UnionVector>

public class AvroUnionsConsumer
extends BaseAvroConsumer<UnionVector>

Consumer which consume unions type values from avro decoder. Write the data to UnionVector.

Field Summary

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

currentIndex, vector

Constructor Summary

Constructors

Constructor and Description
AvroUnionsConsumer(UnionVector vector, Consumer[] delegates, Types.MinorType[] types) Instantiate an AvroUnionConsumer.

Method Summary

Modifier and Type	Method and Description
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(UnionVector vector) Reset the vector within consumer for partial read purpose.

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

addNull, getVector, setPosition

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.consumers.Consumer

skippable

Constructor Detail

AvroUnionsConsumer

public AvroUnionsConsumer(UnionVector vector,
                          Consumer[] delegates,
                          Types.MinorType[] types)

Instantiate an AvroUnionConsumer.

Method Detail

consume

public void consume(org.apache.avro.io.Decoder decoder)
             throws IOException

Description copied from interface: Consumer

Consume a specific type value from avro decoder and write it to vector.

Parameters:

decoder - avro decoder to read data

Throws:

IOException - on error

close

public void close()
           throws Exception

Description copied from interface: Consumer

Close this consumer when occurs exception to avoid potential leak.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Consumer<UnionVector>

Overrides:

close in class BaseAvroConsumer<UnionVector>

Throws:

Exception

resetValueVector

public boolean resetValueVector(UnionVector vector)

Description copied from interface: Consumer

Reset the vector within consumer for partial read purpose.

Specified by:

resetValueVector in interface Consumer<UnionVector>

Overrides:

resetValueVector in class BaseAvroConsumer<UnionVector>

Returns:

true if reset is successful, false if reset is not needed.