Package dev.vortex.jni

Class NativePartition

java.lang.Object

dev.vortex.jni.NativePartition

public final class NativePartition
extends Object

JNI boundary for Partition.

Method Summary

Modifier and Type	Method	Description
static void	free(long pointer)	Free a partition pointer that was not consumed by scanArrow(long, long, long).
static void	rowCount(long pointer, long[] out)	Fill out with [rows, cardinality].
static void	scanArrow(long sessionPointer, long partitionPointer, long streamAddress)	Consume the partition into the FFI_ArrowArrayStream at streamAddress.

Methods inherited from class java.lang.Object

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

Method Details

free

public static void free(long pointer)

Free a partition pointer that was not consumed by scanArrow(long, long, long).

rowCount

public static void rowCount(long pointer,
 long[] out)

Fill out with [rows, cardinality].

scanArrow

public static void scanArrow(long sessionPointer,
 long partitionPointer,
 long streamAddress)

Consume the partition into the FFI_ArrowArrayStream at streamAddress. The partition pointer is invalidated by this call.

Parameters:

sessionPointer - native session pointer used for execution context

partitionPointer - partition pointer to consume

streamAddress - address of an allocated FFI_ArrowArrayStream struct