Skip to main content

Module writer

risingwave_stream::executor::iceberg_with_pk_index

Module writer 

Source

Structs§

WriterExecutor
Writer Executor for iceberg pk-index sink with PK index

Traits§

IcebergWriter
Trait abstracting the Iceberg data file writing for testability.

Functions§

append_row 🔒
new_chunk_builder 🔒

Type Aliases§

PkRow 🔒