Skip to main content

stream_tasks

risingwave_connector::source::iceberg::update_planner

Function stream_tasks 

Source 
fn stream_tasks(
    binding: Arc<IcebergUpdateBinding>,
    table: Table,
    cursor: IcebergUpdateCursor,
) -> BoxStream<'static, ConnectorResult<IcebergUpdateTask>>
Expand description

Plans one range phase as a deterministic stream; recovery replays it up to after_path. Bootstrap enumerates the whole snapshot. Incremental phases diff the manifest lists of the range base and target instead of indexing every live file of either snapshot.