Module batch_iceberg_fetch

risingwave_stream::executor::source::batch_source

Module batch_iceberg_fetch 

Source

Structs§

BatchIcebergFetchExecutor
Executor that fetches data from Iceberg files discovered by an upstream list executor.
ColumnIndices 🔒
Indices of special columns that need to be pruned from output.
FetchState 🔒

Type Aliases§

FileEntry 🔒
Type alias for file entries in the queue: (file_name, scan_task_json)