Module org.apache.arrow.adapter.avro

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

Class DictionaryDecodingProducer<T extends FieldVector>

java.lang.Object

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

org.apache.arrow.adapter.avro.producers.DictionaryDecodingProducer<T>

Type Parameters:

T - Type of the underlying dictionary vector

All Implemented Interfaces:

Producer<BaseIntVector>

public class DictionaryDecodingProducer<T extends FieldVector>
extends BaseAvroProducer<BaseIntVector>

Producer that decodes values from a dictionary-encoded FieldVector, writes the resulting values to an Avro encoder.

Field Summary

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

currentIndex, vector

Constructor Summary

Constructors

Constructor	Description
DictionaryDecodingProducer(BaseIntVector indexVector, Producer<T> dictProducer)	Instantiate a DictionaryDecodingProducer.

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

DictionaryDecodingProducer

public DictionaryDecodingProducer(BaseIntVector indexVector,
 Producer<T> dictProducer)

Instantiate a DictionaryDecodingProducer.

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