risingwave_stream::executor::source

Module iceberg_list_executor

Source

Structs§

IcebergListExecutor

Functions§

incremental_scan_stream 🔒
last_snapshot is EXCLUSIVE (i.e., already scanned)