Type Alias DispatcherMessageBatch 

pub type DispatcherMessageBatch = MessageBatchInner<()>;

Aliased Type

pub enum DispatcherMessageBatch {
    Chunk(StreamChunk),
    BarrierBatch(Vec<BarrierInner<()>>),
    Watermark(Watermark),
}

Variants

Chunk(StreamChunk)

BarrierBatch(Vec<BarrierInner<()>>)

Watermark(Watermark)

Implementations

impl DispatcherMessageBatch

fn into_messages( self, ) -> Either<impl Iterator<Item = DispatcherMessage>, DispatcherMessage>

impl DispatcherMessageBatch

pub fn to_protobuf(&self) -> PbStreamMessageBatch

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

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