Struct BuildFragmentGraphState 

pub struct BuildFragmentGraphState {
    fragment_graph: StreamFragmentGraph,
    next_local_fragment_id: u32,
    next_table_id: u32,
    next_operator_id: u32,
    dependent_table_ids: HashSet<TableId>,
    share_mapping: HashMap<u32, u32>,
    share_stream_node_mapping: HashMap<u32, StreamNode>,
    has_source_backfill: bool,
    has_snapshot_backfill: bool,
    has_cross_db_snapshot_backfill: bool,
}

The mutable state when building fragment graph.

Fields

fragment_graph: StreamFragmentGraph

fragment graph field, transformed from input streaming plan.

next_local_fragment_id: u32

local fragment id

next_table_id: u32

Next local table id to be allocated. It equals to total table ids cnt when finish stream node traversing.

next_operator_id: u32

rewrite will produce new operators, and we need to track next operator id

dependent_table_ids: HashSet<TableId>

dependent streaming job ids.

share_mapping: HashMap<u32, u32>

operator id to LocalFragmentId mapping used by share operator.

share_stream_node_mapping: HashMap<u32, StreamNode>

operator id to StreamNode mapping used by share operator.

has_source_backfill: bool

has_snapshot_backfill: bool

has_cross_db_snapshot_backfill: bool

Implementations

impl BuildFragmentGraphState

fn new_stream_fragment(&mut self) -> StreamFragment

Create a new stream fragment with given node with generating a fragment id.

fn gen_operator_id(&mut self) -> u32

Generate an operator id

pub fn gen_table_id(&mut self) -> u32

Generate an table id

pub fn gen_table_id_wrapped(&mut self) -> TableId

Generate an table id

pub fn add_share_stream_node( &mut self, operator_id: u32, stream_node: StreamNode, )

pub fn get_share_stream_node(&mut self, operator_id: u32) -> Option<&StreamNode>

pub fn gen_no_op_stream_node(&mut self, input: StreamNode) -> StreamNode

Generate a new stream node with NoOp body and the given input. The properties of the stream node will also be copied from the input node.

Trait Implementations

impl Default for BuildFragmentGraphState

where StreamFragmentGraph: Default, u32: Default, HashSet<TableId>: Default, HashMap<u32, u32>: Default, HashMap<u32, StreamNode>: Default, bool: Default,

fn default() -> Self

Returns the “default value” for a type.