org.bytedeco.arrow_dataset

Class ScanTask

java.lang.Object

org.bytedeco.javacpp.Pointer

org.bytedeco.arrow_dataset.ScanTask

All Implemented Interfaces:

AutoCloseable

Direct Known Subclasses:

InMemoryScanTask

@Namespace(value="arrow::dataset")
 @NoOffset
 @Properties(inherit=arrow_dataset.class)
public class ScanTask
extends Pointer

\brief Read record batches from a range of a single data fragment. A ScanTask is meant to be a unit of work to be dispatched. The implementation must be thread and concurrent safe.

Nested Class Summary

Nested classes/interfaces inherited from class org.bytedeco.javacpp.Pointer

Pointer.CustomDeallocator, Pointer.Deallocator, Pointer.NativeDeallocator, Pointer.ReferenceCounter

Field Summary

Fields inherited from class org.bytedeco.javacpp.Pointer

address, capacity, limit, position

Constructor Summary

Constructors

Constructor and Description
ScanTask(Pointer p) Pointer cast constructor.

Method Summary

Modifier and Type	Method and Description
RecordBatchIteratorResult	Execute() \brief Iterate through sequence of materialized record batches resulting from the Scan.
Fragment	fragment()
ScanOptions	options()
RecordBatchVectorFuture	SafeExecute(Executor executor)
Future	SafeVisit(Executor executor, arrow_dataset.RecordBatchVisitor visitor)

Methods inherited from class org.bytedeco.javacpp.Pointer

address, asBuffer, asByteBuffer, availablePhysicalBytes, calloc, capacity, capacity, close, deallocate, deallocate, deallocateReferences, deallocator, deallocator, equals, fill, formatBytes, free, getDirectBufferAddress, getPointer, getPointer, getPointer, getPointer, hashCode, interruptDeallocatorThread, isNull, isNull, limit, limit, malloc, maxBytes, maxPhysicalBytes, memchr, memcmp, memcpy, memmove, memset, offsetAddress, offsetof, offsetof, parseBytes, physicalBytes, physicalBytesInaccurate, position, position, put, realloc, referenceCount, releaseReference, retainReference, setNull, sizeof, sizeof, toString, totalBytes, totalCount, totalPhysicalBytes, withDeallocator, zero

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

ScanTask

public ScanTask(Pointer p)

Pointer cast constructor. Invokes Pointer(Pointer).

Method Detail

Execute

@ByVal
public RecordBatchIteratorResult Execute()

\brief Iterate through sequence of materialized record batches resulting from the Scan. Execution semantics are encapsulated in the particular ScanTask implementation

SafeExecute

@ByVal
public RecordBatchVectorFuture SafeExecute(Executor executor)

SafeVisit

@ByVal
public Future SafeVisit(Executor executor,
                                @ByVal
                                arrow_dataset.RecordBatchVisitor visitor)

options

@SharedPtr
public ScanOptions options()

fragment

@Const
 @SharedPtr
 @ByRef
public Fragment fragment()