Skip to main content

load_data_files

risingwave_connector::source::iceberg::update_planner

Function load_data_files 

Source 
async fn load_data_files(
    binding: &IcebergUpdateBinding,
    table: &Table,
    manifest_file: &ManifestFile,
    max_sequence: i64,
) -> ConnectorResult<Vec<UpdateFile>>
Expand description

Live, validated data files of one data manifest, without delete descriptors.