Module writer 

Parquet writer.

Structs

ObjectStoreWriterFactory

ParquetWriter

Parquet SST writer.

SizeAwareWriter 🔒

Workaround for [AsyncArrowWriter] does not provide a method to get total bytes written after close.

SourceStats 🔒

Enums

FlatBatchConverter 🔒

Converts a flat RecordBatch for writing to parquet.

SeriesBoundarySplit 🔒

Result of splitting a batch at the next series boundary.

Traits

WriterFactory

Functions

encoded_primary_keys 🔒

Returns the dictionary keys and values of the encoded __primary_key column.

split_at_next_series 🔒

Splits batch at the first row whose encoded primary key differs from current_primary_key, the last primary key written to the current file.

timestamp_range_from_array 🔒

Gets min and max timestamp from an timestamp array.