Type Alias PbStreamFragmentGraph

pub type PbStreamFragmentGraph = StreamFragmentGraph;

Alias for StreamFragmentGraph.

Aliased Type

struct PbStreamFragmentGraph {
    pub fragments: HashMap<u32, StreamFragment>,
    pub edges: Vec<StreamFragmentEdge>,
    pub dependent_table_ids: Vec<u32>,
    pub table_ids_cnt: u32,
    pub ctx: Option<StreamContext>,
    pub parallelism: Option<Parallelism>,
    pub max_parallelism: u32,
}

Fields

fragments: HashMap<u32, StreamFragment>

all the fragments in the graph.

edges: Vec<StreamFragmentEdge>

edges between fragments.

dependent_table_ids: Vec<u32>

table_ids_cnt: u32

ctx: Option<StreamContext>

parallelism: Option<Parallelism>

If none, default parallelism will be applied.

max_parallelism: u32

Specified max parallelism, i.e., expected vnode count for the graph.

The scheduler on the meta service will use this as a hint to decide the vnode count for each fragment.

Note that the actual vnode count may be different from this value. For example, a no-shuffle exchange between current fragment graph and an existing upstream fragment graph requires two fragments to be in the same distribution, thus the same vnode count.