Skip to main content

stream_files

risingwave_connector::source::iceberg::update_planner

Function stream_files 

Source 
fn stream_files(
    binding: Arc<IcebergUpdateBinding>,
    table: Table,
    snapshot_id: i64,
) -> Pin<Box<dyn Stream<Item = Result<UpdateFile, ConnectorError>> + Send>>
Expand description

Every live data file of a snapshot, for bootstrap. Delete descriptors are indexed before data enumeration, since manifests are not ordered by referenced data path. Only one data manifest and one task page are materialized at a time, in addition to the delete index.