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

Enums§

WriterInputMode
Input-selection state for the writer’s dual-input compaction protocol.

Traits§

IcebergWriter
Trait abstracting the Iceberg data file writing for testability.

Functions§

append_row 🔒
lookup_index_rows 🔒
Looks up the PK index rows of pks with at most concurrency lookups in flight. Results are returned in the same order as pks.
new_chunk_builder 🔒
next_msg 🔒

Type Aliases§

PkRow 🔒