Type Alias DispatcherMessage

pub type DispatcherMessage = MessageInner<()>;

Aliased Type

enum DispatcherMessage {
    Chunk(StreamChunk),
    Barrier(BarrierInner<()>),
    Watermark(Watermark),
}

Variants

Chunk(StreamChunk)

Barrier(BarrierInner<()>)

Watermark(Watermark)

Implementations

impl DispatcherMessage

pub fn to_protobuf(&self) -> PbStreamMessage

pub fn from_protobuf(prost: &PbStreamMessage) -> StreamExecutorResult<Self>

pub fn get_encoded_len(msg: &impl Message) -> usize