org.bytedeco.parquet

Class ReaderProperties

java.lang.Object

org.bytedeco.javacpp.Pointer

org.bytedeco.parquet.ReaderProperties

All Implemented Interfaces:

AutoCloseable

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

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
ReaderProperties()
ReaderProperties(long size) Native array allocator.
ReaderProperties(MemoryPool pool)
ReaderProperties(Pointer p) Pointer cast constructor.

Method Summary

Modifier and Type	Method and Description
long	buffer_size()
void	disable_buffered_stream()
void	enable_buffered_stream()
FileDecryptionProperties	file_decryption_properties()
void	file_decryption_properties(FileDecryptionProperties decryption)
ReaderProperties	getPointer(long i)
InputStream	GetStream(RandomAccessFile source, long start, long num_bytes)
boolean	is_buffered_stream_enabled() Buffered stream reading allows the user to control the memory usage of parquet readers.
MemoryPool	memory_pool()
ReaderProperties	position(long position)
void	set_buffer_size(long size)

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

ReaderProperties

public ReaderProperties(Pointer p)

Pointer cast constructor. Invokes Pointer(Pointer).

ReaderProperties

public ReaderProperties(long size)

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

ReaderProperties

public ReaderProperties(MemoryPool pool)

ReaderProperties

public ReaderProperties()

Method Detail

position

public ReaderProperties position(long position)

Overrides:

position in class Pointer

getPointer

public ReaderProperties getPointer(long i)

Overrides:

getPointer in class Pointer

memory_pool

public MemoryPool memory_pool()

GetStream

@Cast(value="parquet::ArrowInputStream*")
 @SharedPtr
public InputStream GetStream(@Cast(value="parquet::ArrowInputFile*") @SharedPtr
                                                                                     RandomAccessFile source,
                                                                                     @Cast(value="int64_t")
                                                                                     long start,
                                                                                     @Cast(value="int64_t")
                                                                                     long num_bytes)

is_buffered_stream_enabled

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

Buffered stream reading allows the user to control the memory usage of parquet readers. This ensure that all RandomAccessFile::ReadAt calls are wrapped in a buffered reader that uses a fix sized buffer (of size buffer_size()) instead of the full size of the ReadAt. The primary reason for this control knobs is for resource control and not performance.

enable_buffered_stream

public void enable_buffered_stream()

disable_buffered_stream

public void disable_buffered_stream()

buffer_size

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

set_buffer_size

public void set_buffer_size(@Cast(value="int64_t")
                            long size)

file_decryption_properties

public void file_decryption_properties(@SharedPtr
                                       FileDecryptionProperties decryption)

file_decryption_properties

@SharedPtr
public FileDecryptionProperties file_decryption_properties()