Struct ReplaceStreamJobPlan 

pub struct ReplaceStreamJobPlan {
    pub old_fragments: StreamJobFragments,
    pub new_fragments: StreamJobFragmentsToCreate,
    pub replace_upstream: FragmentReplaceUpstream,
    pub upstream_fragment_downstreams: FragmentDownstreamRelation,
    pub init_split_assignment: SplitAssignment,
    pub streaming_job: StreamingJob,
    pub tmp_id: u32,
    pub to_drop_state_table_ids: Vec<TableId>,
    pub auto_refresh_schema_sinks: Option<Vec<AutoRefreshSchemaSinkContext>>,
    pub cdc_table_snapshot_split_assignment: CdcTableSnapshotSplitAssignment,
}

Replacing an old job with a new one. All actors in the job will be rebuilt.

Current use cases:

• ALTER SOURCE (via Command::ReplaceStreamJob) will replace a source job’s plan.
• ALTER TABLE (via Command::ReplaceStreamJob) and CREATE SINK INTO table (Command::CreateStreamingJob) will replace a table job’s plan.

Fields

old_fragments: StreamJobFragments

new_fragments: StreamJobFragmentsToCreate

replace_upstream: FragmentReplaceUpstream

Downstream jobs of the replaced job need to update their Merge node to connect to the new fragment.

upstream_fragment_downstreams: FragmentDownstreamRelation

init_split_assignment: SplitAssignment

For a table with connector, the SourceExecutor actor will also be rebuilt with new actor ids. We need to reassign splits for it.

Note that there’s no SourceBackfillExecutor involved for table with connector, so we don’t need to worry about backfill_splits.

streaming_job: StreamingJob

The StreamingJob info of the table to be replaced. Must be StreamingJob::Table

tmp_id: u32

The temporary dummy job fragments id of new table fragment

to_drop_state_table_ids: Vec<TableId>

The state table ids to be dropped.

auto_refresh_schema_sinks: Option<Vec<AutoRefreshSchemaSinkContext>>

cdc_table_snapshot_split_assignment: CdcTableSnapshotSplitAssignment

Implementations

impl ReplaceStreamJobPlan

fn fragment_changes(&self) -> HashMap<FragmentId, CommandFragmentChanges>

pub fn fragment_replacements(&self) -> HashMap<FragmentId, FragmentId>

old_fragment_id -> new_fragment_id

Trait Implementations

impl Clone for ReplaceStreamJobPlan

fn clone(&self) -> ReplaceStreamJobPlan

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ReplaceStreamJobPlan

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

Formats the value using the given formatter.