org.apache.arrow.adapter.avro.consumers

Class AvroMapConsumer

java.lang.Object

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

org.apache.arrow.adapter.avro.consumers.AvroMapConsumer

All Implemented Interfaces:

AutoCloseable, Consumer<MapVector>

public class AvroMapConsumer
extends BaseAvroConsumer<MapVector>

Consumer which consume map type values from avro decoder. Write the data to MapVector.

Field Summary

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

currentIndex, vector

Constructor Summary

Constructors

Constructor and Description
AvroMapConsumer(MapVector vector, Consumer delegate) Instantiate a AvroMapConsumer.

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

AvroMapConsumer

public AvroMapConsumer(MapVector vector,
                       Consumer delegate)

Instantiate a AvroMapConsumer.

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

Overrides:

close in class BaseAvroConsumer<MapVector>

Throws:

Exception

resetValueVector

public boolean resetValueVector(MapVector vector)

Description copied from interface: Consumer

Reset the vector within consumer for partial read purpose.

Specified by:

resetValueVector in interface Consumer<MapVector>

Overrides:

resetValueVector in class BaseAvroConsumer<MapVector>

Returns:

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