Struct StreamActor

pub struct StreamActor {
    pub actor_id: u32,
    pub fragment_id: u32,
    pub nodes: Option<StreamNode>,
    pub dispatcher: Vec<Dispatcher>,
    pub upstream_actor_id: Vec<u32>,
    pub vnode_bitmap: Option<Buffer>,
    pub mview_definition: String,
    pub expr_context: Option<ExprContext>,
}

A StreamActor is a running fragment of the overall stream graph,

Fields

actor_id: u32

fragment_id: u32

nodes: Option<StreamNode>

dispatcher: Vec<Dispatcher>

upstream_actor_id: Vec<u32>

The actors that send messages to this actor. Note that upstream actor ids are also stored in the proto of merge nodes. It is painstaking to traverse through the node tree and get upstream actor id from the root StreamNode. We duplicate the information here to ease the parsing logic in stream manager.

vnode_bitmap: Option<Buffer>

Vnodes that the executors in this actor own. If the fragment is a singleton, this field will not be set and leave a None.

mview_definition: String

The SQL definition of this materialized view. Used for debugging only.

expr_context: Option<ExprContext>

Provide the necessary context, e.g. session info like time zone, for the actor.

Implementations

impl StreamActor

pub fn get_actor_id(&self) -> u32

pub fn get_fragment_id(&self) -> u32

pub fn get_nodes(&self) -> Result<&StreamNode, PbFieldNotFound>

pub fn get_dispatcher(&self) -> &Vec<Dispatcher>

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

pub fn get_vnode_bitmap(&self) -> Result<&Buffer, PbFieldNotFound>

pub fn get_mview_definition(&self) -> &String

pub fn get_expr_context(&self) -> Result<&ExprContext, PbFieldNotFound>

Trait Implementations

impl Clone for StreamActor

fn clone(&self) -> StreamActor

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for StreamActor

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

Formats the value using the given formatter.

impl Default for StreamActor

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for StreamActor

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

where D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Message for StreamActor

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 StreamActor

fn eq(&self, other: &StreamActor) -> 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 StreamActor

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 StreamActor