org.bytedeco.parquet

Class FileWriter

java.lang.Object

org.bytedeco.javacpp.Pointer

org.bytedeco.parquet.FileWriter

All Implemented Interfaces:

AutoCloseable

@Namespace(value="parquet::arrow")
 @Properties(inherit=parquet.class)
public class FileWriter
extends Pointer

\brief Iterative FileWriter class Start a new RowGroup or Chunk with NewRowGroup. Write column-by-column the whole column chunk. If PARQUET:field_id is present as a metadata key on a field, and the corresponding value is a nonnegative integer, then it will be used as the field_id in the parquet file.

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
FileWriter(Pointer p) Pointer cast constructor.

Method Summary

Modifier and Type	Method and Description
Status	Close()
static Status	Make(MemoryPool pool, ParquetFileWriter writer, Schema schema, ArrowWriterProperties arrow_properties, FileWriter out)
MemoryPool	memory_pool()
FileMetaData	metadata()
Status	NewRowGroup(long chunk_size)
static Status	Open(Schema schema, MemoryPool pool, OutputStream sink, WriterProperties properties, ArrowWriterProperties arrow_properties, FileWriter writer)
static Status	Open(Schema schema, MemoryPool pool, OutputStream sink, WriterProperties properties, FileWriter writer)
Schema	schema()
Status	WriteColumnChunk(Array data)
Status	WriteColumnChunk(ChunkedArray data)
Status	WriteColumnChunk(ChunkedArray data, long offset, long size) \brief Write ColumnChunk in row group using slice of a ChunkedArray
Status	WriteTable(Table table, long chunk_size) \brief Write a Table to Parquet.

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

FileWriter

public FileWriter(Pointer p)

Pointer cast constructor. Invokes Pointer(Pointer).

Method Detail

Make

@ByVal
public static Status Make(MemoryPool pool,
                                  @UniquePtr
                                  ParquetFileWriter writer,
                                  @SharedPtr @ByVal
                                  Schema schema,
                                  @SharedPtr
                                  ArrowWriterProperties arrow_properties,
                                  @UniquePtr
                                  FileWriter out)

Open

@ByVal
public static Status Open(@Const @ByRef
                                  Schema schema,
                                  MemoryPool pool,
                                  @SharedPtr
                                  OutputStream sink,
                                  @SharedPtr
                                  WriterProperties properties,
                                  @UniquePtr
                                  FileWriter writer)

Open

@ByVal
public static Status Open(@Const @ByRef
                                  Schema schema,
                                  MemoryPool pool,
                                  @SharedPtr
                                  OutputStream sink,
                                  @SharedPtr
                                  WriterProperties properties,
                                  @SharedPtr
                                  ArrowWriterProperties arrow_properties,
                                  @UniquePtr
                                  FileWriter writer)

schema

@SharedPtr
 @ByVal
public Schema schema()

WriteTable

@ByVal
public Status WriteTable(@Const @ByRef
                                 Table table,
                                 @Cast(value="int64_t")
                                 long chunk_size)

\brief Write a Table to Parquet.

NewRowGroup

@ByVal
public Status NewRowGroup(@Cast(value="int64_t")
                                  long chunk_size)

WriteColumnChunk

@ByVal
public Status WriteColumnChunk(@Const @ByRef
                                       Array data)

WriteColumnChunk

@ByVal
public Status WriteColumnChunk(@SharedPtr @Cast(value={"","std::shared_ptr<arrow::ChunkedArray>"})
                                       ChunkedArray data,
                                       @Cast(value="int64_t")
                                       long offset,
                                       @Cast(value="int64_t")
                                       long size)

\brief Write ColumnChunk in row group using slice of a ChunkedArray

WriteColumnChunk

@ByVal
public Status WriteColumnChunk(@SharedPtr @Cast(value={"","std::shared_ptr<arrow::ChunkedArray>"})
                                       ChunkedArray data)

Close

@ByVal
public Status Close()

memory_pool

public MemoryPool memory_pool()

metadata

@SharedPtr
public FileMetaData metadata()