org.bytedeco.parquet

Class ArrowReaderProperties

java.lang.Object

org.bytedeco.javacpp.Pointer

org.bytedeco.parquet.ArrowReaderProperties

All Implemented Interfaces:

AutoCloseable

@Namespace(value="parquet")
 @NoOffset
 @Properties(inherit=parquet.class)
public class ArrowReaderProperties
extends Pointer

EXPERIMENTAL: Properties for configuring FileReader behavior.

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
ArrowReaderProperties()
ArrowReaderProperties(boolean use_threads)
ArrowReaderProperties(long size) Native array allocator.
ArrowReaderProperties(Pointer p) Pointer cast constructor.

Method Summary

Modifier and Type	Method and Description
long	batch_size()
CacheOptions	cache_options()
TimeUnit.type	coerce_int96_timestamp_unit()
ArrowReaderProperties	getPointer(long i)
IOContext	io_context()
ArrowReaderProperties	position(long position)
boolean	pre_buffer()
boolean	read_dictionary(int column_index)
void	set_batch_size(long batch_size)
void	set_cache_options(CacheOptions options) Set options for read coalescing.
void	set_coerce_int96_timestamp_unit(int unit)
void	set_coerce_int96_timestamp_unit(TimeUnit.type unit) Set timestamp unit to use for deprecated INT96-encoded timestamps (default is NANO).
void	set_io_context(IOContext ctx) Set execution context for read coalescing.
void	set_pre_buffer(boolean pre_buffer) Enable read coalescing.
void	set_read_dictionary(int column_index, boolean read_dict)
void	set_use_threads(boolean use_threads)
boolean	use_threads()

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, hashCode, interruptDeallocatorThread, isNull, isNull, limit, limit, malloc, maxBytes, maxPhysicalBytes, memchr, memcmp, memcpy, memmove, memset, offsetAddress, offsetof, offsetof, parseBytes, physicalBytes, physicalBytesInaccurate, 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

ArrowReaderProperties

public ArrowReaderProperties(Pointer p)

Pointer cast constructor. Invokes Pointer(Pointer).

ArrowReaderProperties

public ArrowReaderProperties(long size)

Native array allocator. Access with Pointer.position(long).

ArrowReaderProperties

public ArrowReaderProperties(@Cast(value="bool")
                             boolean use_threads)

ArrowReaderProperties

public ArrowReaderProperties()

Method Detail

position

public ArrowReaderProperties position(long position)

Overrides:

position in class Pointer

getPointer

public ArrowReaderProperties getPointer(long i)

Overrides:

getPointer in class Pointer

set_use_threads

public void set_use_threads(@Cast(value="bool")
                            boolean use_threads)

use_threads

@Cast(value="bool")
public boolean use_threads()

set_read_dictionary

public void set_read_dictionary(int column_index,
                                @Cast(value="bool")
                                boolean read_dict)

read_dictionary

@Cast(value="bool")
public boolean read_dictionary(int column_index)

set_batch_size

public void set_batch_size(@Cast(value="int64_t")
                           long batch_size)

batch_size

@Cast(value="int64_t")
public long batch_size()

set_pre_buffer

public void set_pre_buffer(@Cast(value="bool")
                           boolean pre_buffer)

Enable read coalescing. When enabled, the Arrow reader will pre-buffer necessary regions of the file in-memory. This is intended to improve performance on high-latency filesystems (e.g. Amazon S3).

pre_buffer

@Cast(value="bool")
public boolean pre_buffer()

set_cache_options

public void set_cache_options(@ByVal
                              CacheOptions options)

Set options for read coalescing. This can be used to tune the implementation for characteristics of different filesystems.

cache_options

@Const
 @ByRef
public CacheOptions cache_options()

set_io_context

public void set_io_context(@Const @ByRef
                           IOContext ctx)

Set execution context for read coalescing.

io_context

@Const
 @ByRef
public IOContext io_context()

set_coerce_int96_timestamp_unit

public void set_coerce_int96_timestamp_unit(TimeUnit.type unit)

Set timestamp unit to use for deprecated INT96-encoded timestamps (default is NANO).

set_coerce_int96_timestamp_unit

public void set_coerce_int96_timestamp_unit(@Cast(value="arrow::TimeUnit::type")
                                            int unit)

coerce_int96_timestamp_unit

public TimeUnit.type coerce_int96_timestamp_unit()