risingwave_pb::compactor

Type Alias PbDispatchCompactionTaskRequest

source
pub type PbDispatchCompactionTaskRequest = DispatchCompactionTaskRequest;
Expand description

Aliased Type§

struct PbDispatchCompactionTaskRequest {
    pub tables: Vec<Table>,
    pub output_object_ids: Vec<u64>,
    pub task: Option<Task>,
}

Fields§

§tables: Vec<Table>

Used to build filter_key_extract.

§output_object_ids: Vec<u64>

We can generate output object ids for each compactor, which equal to the number of input SSTs. If all the output object ids are used up, this compaction task fails, and the next allocation will be twice the previous amount of output object ids.

§task: Option<Task>

DispatchCompactionTaskRequest is used to pass compaction task level parameters.