Module org.apache.arrow.adapter.avro

Package org.apache.arrow.adapter.avro.producers

Class AvroBigIntProducer

java.lang.Object

org.apache.arrow.adapter.avro.producers.BaseAvroProducer<BaseFixedWidthVector>

org.apache.arrow.adapter.avro.producers.AvroBigIntProducer

All Implemented Interfaces:

Producer<BaseFixedWidthVector>

Direct Known Subclasses:

AvroTimeMicroProducer, AvroTimestampMicroProducer, AvroTimestampMicroTzProducer, AvroTimestampMilliProducer, AvroTimestampMilliTzProducer, AvroTimestampNanoProducer, AvroTimestampNanoTzProducer

public class AvroBigIntProducer
extends BaseAvroProducer<BaseFixedWidthVector>

Producer that produces long values from a BigIntVector, writes data to an Avro encoder.

Logical types are also supported, for vectors derived from BaseFixedWidthVector where the internal representation matches BigIntVector and requires no conversion.

Field Summary

Fields inherited from class org.apache.arrow.adapter.avro.producers.BaseAvroProducer

currentIndex, vector

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AvroBigIntProducer(BaseFixedWidthVector vector)	Protected constructor for logical types with a long representation.
	AvroBigIntProducer(BigIntVector vector)	Instantiate an AvroBigIntProducer.

Method Summary

Modifier and Type	Method	Description
void	produce(org.apache.avro.io.Encoder encoder)	Produce a specific type value from the vector and write it to avro encoder.

Methods inherited from class org.apache.arrow.adapter.avro.producers.BaseAvroProducer

getVector, resetValueVector, setPosition, skipNull

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

AvroBigIntProducer

public AvroBigIntProducer(BigIntVector vector)

Instantiate an AvroBigIntProducer.

AvroBigIntProducer

protected AvroBigIntProducer(BaseFixedWidthVector vector)

Protected constructor for logical types with a long representation.

Method Details

produce

public void produce(org.apache.avro.io.Encoder encoder)
             throws IOException

Description copied from interface: Producer

Produce a specific type value from the vector and write it to avro encoder.

Parameters:

encoder - avro encoder to write data

Throws:

IOException - on error