Skip to main content

PbIcebergPkIndexCompactionContext

risingwave_pb::stream_plan

Type Alias PbIcebergPkIndexCompactionContext 

Source 
pub type PbIcebergPkIndexCompactionContext = IcebergPkIndexCompactionContext;

Aliased Type§

pub struct PbIcebergPkIndexCompactionContext {
    pub sink_id: TypedId<7, u32>,
    pub task_id: TypedId<11, u64>,
    pub phase: i32,
    pub resolver_task_input: Option<ResolverTaskInput>,
}

Fields§

§sink_id: TypedId<7, u32>§task_id: TypedId<11, u64>§phase: i32§resolver_task_input: Option<ResolverTaskInput>

Required for PHASE_BEGIN and absent for PHASE_END.