Type Alias PbDispatcher

pub type PbDispatcher = Dispatcher;

Alias for Dispatcher.

Aliased Type

struct PbDispatcher {
    pub type: i32,
    pub dist_key_indices: Vec<u32>,
    pub output_indices: Vec<u32>,
    pub hash_mapping: Option<ActorMapping>,
    pub dispatcher_id: u64,
    pub downstream_actor_id: Vec<u32>,
}

Fields

type: i32

dist_key_indices: Vec<u32>

Indices of the columns to be used for hashing. For dispatcher types other than HASH, this is ignored.

output_indices: Vec<u32>

Indices of the columns to output. In most cases, this contains all columns in the input. But for some cases like MV on MV or schema change, we may only output a subset of the columns.

hash_mapping: Option<ActorMapping>

The hash mapping for consistent hash. For dispatcher types other than HASH, this is ignored.

dispatcher_id: u64

Dispatcher can be uniquely identified by a combination of actor id and dispatcher id. This is exactly the same as its downstream fragment id.

downstream_actor_id: Vec<u32>

Number of downstreams decides how many endpoints a dispatcher should dispatch.