risingwave_pb::stream_plan

Type Alias PbStreamNode

source 
pub type PbStreamNode = StreamNode;
Expand description

Alias for StreamNode.

Aliased Type§

struct PbStreamNode {
    pub operator_id: u64,
    pub input: Vec<StreamNode>,
    pub stream_key: Vec<u32>,
    pub append_only: bool,
    pub identity: String,
    pub fields: Vec<Field>,
    pub node_body: Option<NodeBody>,
}

Fields§

§operator_id: u64

The id for the operator. This is local per mview. TODO: should better be a uint32.

§input: Vec<StreamNode>

Child node in plan aka. upstream nodes in the streaming DAG

§stream_key: Vec<u32>§append_only: bool§identity: String§fields: Vec<Field>

The schema of the plan node

§node_body: Option<NodeBody>