risingwave_pb::task_service

Type Alias PbFastInsertRequest

source
pub type PbFastInsertRequest = FastInsertRequest;
Expand description

Alias for FastInsertRequest.

Aliased Type§

struct PbFastInsertRequest {
    pub table_id: u32,
    pub table_version_id: u64,
    pub column_indices: Vec<u32>,
    pub data_chunk: Option<DataChunk>,
    pub row_id_index: Option<u32>,
    pub request_id: u32,
    pub wait_for_persistence: bool,
}

Fields§

§table_id: u32

Id of the table to perform inserting.

§table_version_id: u64

Version of the table.

§column_indices: Vec<u32>§data_chunk: Option<DataChunk>§row_id_index: Option<u32>

An optional field and will be None for tables without user-defined pk. The BatchInsertExecutor should add a column with NULL value which will be filled in streaming.

§request_id: u32

Use this number to assign the insert req to different worker nodes and dml channels.

§wait_for_persistence: bool

TODO(kexiang): add support for default columns. plan_common.ExprContext expr_context is needed for it.