Skip to main content

write_position_delete_chunk

risingwave_connector::sink::iceberg::position_delete

Function write_position_delete_chunk 

Source 
async fn write_position_delete_chunk(
    writer: &mut ParquetWriter,
    arrow_schema: &SchemaRef,
    data_file_path: &str,
    positions: Vec<i64>,
) -> Result<()>
Expand description

Writes one chunk of positions as a (file_path, pos) batch into writer. Every row shares data_file_path because the delete file is file-scoped.