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 🔒

SstWriteContext 🔒

Protection and resource limits travel together for table-compaction output.

SstWriteLimits 🔒

Optional limits used by multi-output compaction. A batch may temporarily exceed the working threshold before its check; callers reserve that workspace.

WriteMemory 🔒

Tracks retained footer memory across rolled files as well as the current file.

Enums

FlatBatchConverter 🔒

Converts a flat RecordBatch for writing to parquet.

SeriesBoundarySplit 🔒

Result of splitting a batch at the next series boundary.

SstArrowWriter 🔒

Arrow writer of the current SST file.

Traits

SstWriteGuard

Registers durable ownership before either an SST or its index is published to storage.

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.