Skip to main content

run_compaction

Function run_compaction 

Source
pub async fn run_compaction(
    table: DeltaTable,
    target_file_size: u64,
    z_order_columns: &[String],
) -> Result<(DeltaTable, CompactionResult), ConnectorError>
Expand description

Runs an OPTIMIZE compaction on a Delta Lake table.

Compacts small Parquet files into larger ones (target size), optionally applying Z-ORDER clustering.

ยงErrors

Returns ConnectorError::Internal if the operation fails.