Package org.apache.arrow.adapter.avro

Class AvroToArrowVectorIterator

java.lang.Object

org.apache.arrow.adapter.avro.AvroToArrowVectorIterator

All Implemented Interfaces:

AutoCloseable, Iterator<VectorSchemaRoot>

public class AvroToArrowVectorIterator
extends Object
implements Iterator<VectorSchemaRoot>, AutoCloseable

VectorSchemaRoot iterator for partially converting avro data.

Field Summary

Fields

Modifier and Type	Field	Description
static final int	DEFAULT_BATCH_SIZE
static final int	NO_LIMIT_BATCH_SIZE

Method Summary

Modifier and Type	Method	Description
void	close()	Clean up resources.
static AvroToArrowVectorIterator	create(org.apache.avro.io.Decoder decoder, org.apache.avro.Schema schema, AvroToArrowConfig config)	Create a ArrowVectorIterator to partially convert data.
boolean	hasNext()
VectorSchemaRoot	next()	Gets the next vector.

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Iterator

forEachRemaining, remove

Field Details

NO_LIMIT_BATCH_SIZE

public static final int NO_LIMIT_BATCH_SIZE

See Also:

• Constant Field Values

DEFAULT_BATCH_SIZE

public static final int DEFAULT_BATCH_SIZE

See Also:

• Constant Field Values

Method Details

create

public static AvroToArrowVectorIterator create(org.apache.avro.io.Decoder decoder,
 org.apache.avro.Schema schema,
 AvroToArrowConfig config)

Create a ArrowVectorIterator to partially convert data.

hasNext

public boolean hasNext()

Specified by:

hasNext in interface Iterator<VectorSchemaRoot>

next

public VectorSchemaRoot next()

Gets the next vector. The user is responsible for freeing its resources.

Specified by:

next in interface Iterator<VectorSchemaRoot>

close

public void close()

Clean up resources.

Specified by:

close in interface AutoCloseable