org.apache.arrow.adapter.avro.consumers

Class AvroArraysConsumer

java.lang.Object

org.apache.arrow.adapter.avro.consumers.BaseAvroConsumer<ListVector>

org.apache.arrow.adapter.avro.consumers.AvroArraysConsumer

All Implemented Interfaces:

AutoCloseable, Consumer<ListVector>

public class AvroArraysConsumer
extends BaseAvroConsumer<ListVector>

Consumer which consume array type values from avro decoder. Write the data to ListVector.

Field Summary

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

currentIndex, vector

Constructor Summary

Constructors

Constructor and Description
AvroArraysConsumer(ListVector vector, Consumer delegate) Instantiate a ArrayConsumer.

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(ListVector vector) Reset the vector within consumer for partial read purpose.

Methods inherited from class org.apache.arrow.adapter.avro.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.adapter.avro.consumers.Consumer

skippable

Constructor Detail

AvroArraysConsumer

public AvroArraysConsumer(ListVector vector,
                          Consumer delegate)

Instantiate a ArrayConsumer.

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<ListVector>

Overrides:

close in class BaseAvroConsumer<ListVector>

Throws:

Exception

resetValueVector

public boolean resetValueVector(ListVector vector)

Description copied from interface: Consumer

Reset the vector within consumer for partial read purpose.

Specified by:

resetValueVector in interface Consumer<ListVector>

Overrides:

resetValueVector in class BaseAvroConsumer<ListVector>

Returns:

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