Module writer

risingwave_stream::executor::iceberg_with_pk_index

Module writer 

Source

Structs§

WriterExecutor
Writer Executor for Iceberg V3 Sink with PK index

Traits§

IcebergWriter
Trait abstracting the Iceberg data file writing for testability.

Functions§

append_row 🔒
new_chunk_builder 🔒

Type Aliases§

IcebergWriterFlushOutput
PkRow 🔒