Package dev.vortex.api

Class Partition

java.lang.Object

dev.vortex.api.Partition

public final class Partition
extends Object

A unit of scan work that materializes into an Arrow stream. Partitions are single-pass: calling scanArrow(BufferAllocator) consumes the partition and transfers ownership of its native memory to the returned ArrowReader. If the partition is never consumed, its native memory is released automatically via VortexCleaner.

Method Summary

Modifier and Type	Method	Description
OptionalLong	rowCount()	Estimated row count of the partition.
org.apache.arrow.vector.ipc.ArrowReader	scanArrow(org.apache.arrow.memory.BufferAllocator allocator)	Consume the partition and return an ArrowReader that yields record batches.

Methods inherited from class java.lang.Object

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

Method Details

rowCount

public OptionalLong rowCount()

Estimated row count of the partition. Empty when unknown.

scanArrow

public org.apache.arrow.vector.ipc.ArrowReader scanArrow(org.apache.arrow.memory.BufferAllocator allocator)

Consume the partition and return an ArrowReader that yields record batches. The caller must close the reader when finished; doing so releases the native partition resources as well.