Structsยง
- Stream
Iceberg With PkIndex Writer StreamIcebergWithPkIndexWriteris 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 ๐