iceberg::parquet::ParquetWriter Class Reference

A writer that writes ArrowArray to Parquet files. More...

#include <parquet_writer.h>

Inheritance diagram for iceberg::parquet::ParquetWriter:

Classes
class	Impl

Public Member Functions
Status	Open (const WriterOptions &options) final
	Open the writer.
Status	Close () final
	Close the writer.
Status	Write (ArrowArray *array) final
	Write arrow data to the file.
Result< Metrics >	metrics () final
	Get the file statistics. Only valid after the file is closed.
Result< int64_t >	length () final
	Get the file length. This can be called while the writer is still open or after the file is closed.
std::vector< int64_t >	split_offsets () final
	Returns a list of recommended split locations, if applicable, empty otherwise. When available, this information is used for planning scan tasks whose boundaries are determined by these offsets. The returned list must be sorted in ascending order. Only valid after the file is closed.
Public Member Functions inherited from iceberg::Writer
	Writer (const Writer &)=delete
Writer &	operator= (const Writer &)=delete

Detailed Description

A writer that writes ArrowArray to Parquet files.

Member Function Documentation

Close()

Status iceberg::parquet::ParquetWriter::Close ( )

finalvirtual

Close the writer.

Implements iceberg::Writer.

length()

Result< int64_t > iceberg::parquet::ParquetWriter::length ( )

finalvirtual

Get the file length. This can be called while the writer is still open or after the file is closed.

Implements iceberg::Writer.

metrics()

Result< Metrics > iceberg::parquet::ParquetWriter::metrics ( )

finalvirtual

Get the file statistics. Only valid after the file is closed.

Implements iceberg::Writer.

Open()

Status iceberg::parquet::ParquetWriter::Open ( const WriterOptions &  options )

finalvirtual

Open the writer.

Implements iceberg::Writer.

split_offsets()

std::vector< int64_t > iceberg::parquet::ParquetWriter::split_offsets ( )

finalvirtual

Returns a list of recommended split locations, if applicable, empty otherwise. When available, this information is used for planning scan tasks whose boundaries are determined by these offsets. The returned list must be sorted in ascending order. Only valid after the file is closed.

Implements iceberg::Writer.

Write()

Status iceberg::parquet::ParquetWriter::Write ( ArrowArray *  data )

finalvirtual

Write arrow data to the file.

Returns

Status of write results.

Note

Ownership of the data is transferred to the writer.

Implements iceberg::Writer.

---

The documentation for this class was generated from the following files:

• iceberg/parquet/parquet_writer.h
• iceberg/parquet/parquet_writer.cc