Type Alias PbDispatcher

pub type PbDispatcher = Dispatcher;

Aliased Type

struct PbDispatcher {
    pub type: i32,
    pub dist_key_indices: Vec<u32>,
    pub output_mapping: Option<DispatchOutputMapping>,
    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_mapping: Option<DispatchOutputMapping>

The method to map the upstream columns in the dispatcher before dispatching.

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.