org.bytedeco.parquet

Class PageReader

java.lang.Object

org.bytedeco.javacpp.Pointer

org.bytedeco.parquet.PageReader

All Implemented Interfaces:

AutoCloseable

@Namespace(value="parquet")
 @Properties(inherit=parquet.class)
public class PageReader
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
PageReader(Pointer p) Pointer cast constructor.

Method Summary

Modifier and Type	Method and Description
Page	NextPage()
static PageReader	Open(InputStream stream, long total_num_rows, Compression.type codec)
static PageReader	Open(InputStream stream, long total_num_rows, Compression.type codec, MemoryPool pool, CryptoContext ctx)
static PageReader	Open(InputStream stream, long total_num_rows, int codec)
static PageReader	Open(InputStream stream, long total_num_rows, int codec, MemoryPool pool, CryptoContext ctx)
void	set_max_page_header_size(int 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, 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

PageReader

public PageReader(Pointer p)

Pointer cast constructor. Invokes Pointer(Pointer).

Method Detail

Open

@UniquePtr
public static PageReader Open(@Cast(value="parquet::ArrowInputStream*") @SharedPtr
                                          InputStream stream,
                                          @Cast(value="int64_t")
                                          long total_num_rows,
                                          Compression.type codec,
                                          MemoryPool pool,
                                          @Const
                                          CryptoContext ctx)

Open

@UniquePtr
public static PageReader Open(@Cast(value="parquet::ArrowInputStream*") @SharedPtr
                                          InputStream stream,
                                          @Cast(value="int64_t")
                                          long total_num_rows,
                                          Compression.type codec)

Open

@UniquePtr
public static PageReader Open(@Cast(value="parquet::ArrowInputStream*") @SharedPtr
                                          InputStream stream,
                                          @Cast(value="int64_t")
                                          long total_num_rows,
                                          @Cast(value="arrow::Compression::type")
                                          int codec,
                                          MemoryPool pool,
                                          @Const
                                          CryptoContext ctx)

Open

@UniquePtr
public static PageReader Open(@Cast(value="parquet::ArrowInputStream*") @SharedPtr
                                          InputStream stream,
                                          @Cast(value="int64_t")
                                          long total_num_rows,
                                          @Cast(value="arrow::Compression::type")
                                          int codec)

NextPage

@SharedPtr
public Page NextPage()

set_max_page_header_size

public void set_max_page_header_size(@Cast(value="uint32_t")
                                     int size)