Module stream_iceberg_with_pk_index_writer

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 ๐Ÿ”’