org.apache.arrow.adapter.avro.consumers

Class AvroStructConsumer

java.lang.Object

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

org.apache.arrow.adapter.avro.consumers.AvroStructConsumer

All Implemented Interfaces:

AutoCloseable, Consumer<StructVector>

public class AvroStructConsumer
extends BaseAvroConsumer<StructVector>

Consumer which consume nested record type values from avro decoder. Write the data to StructVector.

Field Summary

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

currentIndex, vector

Constructor Summary

Constructors

Constructor and Description
AvroStructConsumer(StructVector vector, Consumer[] delegates) Instantiate a AvroStructConsumer.

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(StructVector 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

AvroStructConsumer

public AvroStructConsumer(StructVector vector,
                          Consumer[] delegates)

Instantiate a AvroStructConsumer.

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

Overrides:

close in class BaseAvroConsumer<StructVector>

Throws:

Exception

resetValueVector

public boolean resetValueVector(StructVector vector)

Description copied from interface: Consumer

Reset the vector within consumer for partial read purpose.

Specified by:

resetValueVector in interface Consumer<StructVector>

Overrides:

resetValueVector in class BaseAvroConsumer<StructVector>

Returns:

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