Struct Dispatcher

pub struct Dispatcher {
    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>,
}

A dispatcher redistribute messages. We encode both the type and other usage information in the proto.

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.

Implementations

impl Dispatcher

pub fn type(&self) -> DispatcherType

Returns the enum value of type, or the default if the field is set to an invalid enum value.

pub fn set_type(&mut self, value: DispatcherType)

Sets type to the provided enum value.

impl Dispatcher

pub fn get_type(&self) -> Result<DispatcherType, PbFieldNotFound>

pub fn get_dist_key_indices(&self) -> &Vec<u32>

pub fn get_output_indices(&self) -> &Vec<u32>

pub fn get_hash_mapping(&self) -> Result<&ActorMapping, PbFieldNotFound>

pub fn get_dispatcher_id(&self) -> u64

pub fn get_downstream_actor_id(&self) -> &Vec<u32>

impl Dispatcher

pub fn as_strategy(&self) -> DispatchStrategy

Trait Implementations

impl Clone for Dispatcher

fn clone(&self) -> Dispatcher

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Dispatcher

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for Dispatcher

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for Dispatcher

fn deserialize<D>(deserializer: D) -> Result<Self, D::Error>

where D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Message for Dispatcher

fn encoded_len(&self) -> usize

Returns the encoded length of the message without a length delimiter.

fn clear(&mut self)

Clears the message, resetting all fields to their default.

fn encode(&self, buf: &mut impl BufMut) -> Result<(), EncodeError>

where Self: Sized,

Encodes the message to a buffer.

fn encode_to_vec(&self) -> Vec<u8>

where Self: Sized,

Encodes the message to a newly allocated buffer.

fn encode_length_delimited( &self, buf: &mut impl BufMut, ) -> Result<(), EncodeError>

where Self: Sized,

Encodes the message with a length-delimiter to a buffer.

fn encode_length_delimited_to_vec(&self) -> Vec<u8>

where Self: Sized,

Encodes the message with a length-delimiter to a newly allocated buffer.

fn decode(buf: impl Buf) -> Result<Self, DecodeError>

where Self: Default,

Decodes an instance of the message from a buffer.

fn decode_length_delimited(buf: impl Buf) -> Result<Self, DecodeError>

where Self: Default,

Decodes a length-delimited instance of the message from the buffer.

fn merge(&mut self, buf: impl Buf) -> Result<(), DecodeError>

where Self: Sized,

Decodes an instance of the message from a buffer, and merges it into self.

fn merge_length_delimited(&mut self, buf: impl Buf) -> Result<(), DecodeError>

where Self: Sized,

Decodes a length-delimited instance of the message from buffer, and merges it into self.

impl PartialEq for Dispatcher

fn eq(&self, other: &Dispatcher) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for Dispatcher

fn serialize<S>(&self, serializer: S) -> Result<S::Ok, S::Error>

where S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for Dispatcher