Module org.apache.arrow.adapter.avro

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

Class CompositeAvroProducer

java.lang.Object

org.apache.arrow.adapter.avro.producers.CompositeAvroProducer

public class CompositeAvroProducer
extends Object

Composite producer which holds all producers. It manages the produce and cleanup process.

Constructor Summary

Constructors

Constructor	Description
CompositeAvroProducer(List<Producer<? extends FieldVector>> producers)

Method Summary

Modifier and Type	Method	Description
List<Producer<?>>	getProducers()
void	produce(org.apache.avro.io.Encoder encoder)	Produce encoder data.
void	resetProducerVectors(VectorSchemaRoot root)	Reset vector of consumers with the given VectorSchemaRoot.

Methods inherited from class java.lang.Object

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

Constructor Details

CompositeAvroProducer

public CompositeAvroProducer(List<Producer<? extends FieldVector>> producers)

Method Details

getProducers

public List<Producer<?>> getProducers()

produce

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

Produce encoder data.

Throws:

IOException

resetProducerVectors

public void resetProducerVectors(VectorSchemaRoot root)

Reset vector of consumers with the given VectorSchemaRoot.