Module parquet_writer 

Structs

AsyncWriter

Bridges opendal [Writer] with parquet [AsyncFileWriter].

ParquetFileWriter

Encodes batches on a blocking runtime and writes one object-store file. Callers must await each operation before aborting; dropping an in-flight operation can leave a filesystem worker running after cleanup.

ParquetWriterLimits

Limits for one Parquet file. Flush thresholds are not hard memory caps.

Enums

ParquetCreationPolicy

Destination creation policy; conditional failures never authorize path deletion.

ParquetSink 🔒

Functions

build_encoder 🔒

check_cancelled 🔒