risingwave_pb::stream_plan

Type Alias PbDispatcherType

source
pub type PbDispatcherType = DispatcherType;
Expand description

Alias for DispatcherType.

Aliased Type§

enum PbDispatcherType {
    Unspecified = 0,
    Hash = 1,
    Broadcast = 2,
    Simple = 3,
    NoShuffle = 4,
}

Variants§

§

Unspecified = 0

§

Hash = 1

Dispatch by hash key, hashed by consistent hash.

§

Broadcast = 2

Broadcast to all downstreams.

Note a broadcast cannot be represented as multiple simple dispatchers, since they are different when we update dispatchers during scaling.

§

Simple = 3

Only one downstream.

§

NoShuffle = 4

A special kind of exchange that doesn’t involve shuffle. The upstream actor will be directly piped into the downstream actor, if there are the same number of actors. If number of actors are not the same, should use hash instead. Should be only used when distribution is the same.