Skip to main content

PbIcebergCompactionTask

Type Alias PbIcebergCompactionTask 

Source
pub type PbIcebergCompactionTask = IcebergCompactionTask;

Aliased Type§

pub struct PbIcebergCompactionTask {
    pub task_id: TypedId<11, u64>,
    pub props: BTreeMap<String, String>,
    pub task_type: i32,
    pub sink_id: u32,
    pub pk_index_coordinated: bool,
}

Fields§

§task_id: TypedId<11, u64>§props: BTreeMap<String, String>

compactor will get the information of the iceberg table from the properties

§task_type: i32§sink_id: u32§pk_index_coordinated: bool

Whether this task should be routed through the meta-coordinated commit path for iceberg pk-index sinks, the compactor performs the rewrite without committing and reports the result back to meta instead.