risingwave_stream::executor::source

Module iceberg_fetch_executor

Source

Modules§

state 🔒

Structs§

ChunksWithState 🔒
Fetched data from 1 [FileScanTask], along with states for checkpointing.
IcebergFetchExecutor
An executor that fetches data from Iceberg tables.