Struct BuildingFragment

pub(super) struct BuildingFragment {
    inner: StreamFragment,
    job_id: Option<u32>,
    upstream_table_columns: HashMap<TableId, Vec<i32>>,
}

The fragment in the building phase, including the StreamFragment from the frontend and several additional helper fields.

Fields

inner: StreamFragment

The fragment structure from the frontend, with the global fragment ID.

job_id: Option<u32>

The ID of the job if it contains the streaming job node.

upstream_table_columns: HashMap<TableId, Vec<i32>>

The required column IDs of each upstream table. Will be converted to indices when building the edge connected to the upstream.

For shared CDC table on source, its vec![], since the upstream source’s output schema is fixed.

Implementations

impl BuildingFragment

fn new( id: GlobalId<{ IdCategory::Fragment }>, fragment: StreamFragment, job: &StreamingJob, table_id_gen: GlobalIdGen<{ IdCategory::Table }>, ) -> Self

Create a new BuildingFragment from a StreamFragment. The global fragment ID and global table IDs will be correctly filled with the given id and table_id_gen.

fn extract_internal_tables(&self) -> Vec<Table>

Extract the internal tables from the fragment.

fn fill_internal_tables( fragment: &mut StreamFragment, job: &StreamingJob, table_id_gen: GlobalIdGen<{ IdCategory::Table }>, )

Fill the information with the internal tables in the fragment.

fn fill_job(fragment: &mut StreamFragment, job: &StreamingJob) -> bool

Fill the information with the job in the fragment.

fn extract_upstream_table_columns( fragment: &mut StreamFragment, ) -> HashMap<TableId, Vec<i32>>

Extract the required columns (in IDs) of each upstream table.

pub fn has_shuffled_backfill(&self) -> bool

Methods from Deref<Target = StreamFragment>

pub fn get_fragment_id(&self) -> u32

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

pub fn get_fragment_type_mask(&self) -> u32

pub fn get_requires_singleton(&self) -> bool

pub fn get_table_ids_cnt(&self) -> u32

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

Trait Implementations

impl Clone for BuildingFragment

fn clone(&self) -> BuildingFragment

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for BuildingFragment

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

Formats the value using the given formatter.

impl Deref for BuildingFragment

type Target = StreamFragment

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl DerefMut for BuildingFragment

fn deref_mut(&mut self) -> &mut Self::Target

Mutably dereferences the value.