Module org.apache.arrow.adapter.avro

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

Class AvroDecimalConsumer

java.lang.Object

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

org.apache.arrow.adapter.avro.consumers.logical.AvroDecimalConsumer

All Implemented Interfaces:

AutoCloseable, Consumer<DecimalVector>

Direct Known Subclasses:

AvroDecimalConsumer.BytesDecimalConsumer, AvroDecimalConsumer.FixedDecimalConsumer

public abstract class AvroDecimalConsumer
extends BaseAvroConsumer<DecimalVector>

Consumer which consume decimal type values from avro decoder. Write the data to DecimalVector.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	AvroDecimalConsumer.BytesDecimalConsumer	Consumer for decimal logical type with original bytes type.
static class	AvroDecimalConsumer.FixedDecimalConsumer	Consumer for decimal logical type with original fixed type.

Field Summary

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

currentIndex, vector

Constructor Summary

Constructors

Constructor	Description
AvroDecimalConsumer(DecimalVector vector)	Instantiate a AvroDecimalConsumer.

Method Summary

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

addNull, close, getVector, resetValueVector, 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

consume, skippable

Constructor Details

AvroDecimalConsumer

public AvroDecimalConsumer(DecimalVector vector)

Instantiate a AvroDecimalConsumer.