pub type PbStreamNode = StreamNode;Aliased Type§
pub struct PbStreamNode {
pub operator_id: u64,
pub input: Vec<StreamNode>,
pub stream_key: Vec<u32>,
pub stream_kind: i32,
pub identity: String,
pub fields: Vec<Field>,
pub node_body: Option<NodeBody>,
}Fields§
§operator_id: u64The 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>§stream_kind: i32§identity: String§fields: Vec<Field>The schema of the plan node
node_body: Option<NodeBody>