Skip to main content

Module stream_iceberg_with_pk_index_writer

risingwave_frontend::optimizer::plan_node

Module stream_iceberg_with_pk_index_writer 

Source

Structs§

StreamIcebergWithPkIndexWriter
StreamIcebergWithPkIndexWriter is the stateful writer executor for the Iceberg with pk index sink. It maintains a PK index and writes data files to Iceberg.

Functions§

build_iceberg_pk_state_table 🔒
output_schema 🔒
resolver_output_schema 🔒
Schema of the transient compaction resolver output consumed by the writer’s right input.