Struct ReplaceTablePlan

pub struct ReplaceTablePlan {
    pub old_table_fragments: TableFragments,
    pub new_table_fragments: TableFragments,
    pub merge_updates: Vec<MergeUpdate>,
    pub dispatchers: HashMap<ActorId, Vec<Dispatcher>>,
    pub init_split_assignment: SplitAssignment,
    pub streaming_job: StreamingJob,
    pub tmp_id: u32,
}

Replacing an old table with a new one. All actors in the table job will be rebuilt. Used for ALTER TABLE (Command::ReplaceTable) and sink into table (Command::CreateStreamingJob).

Fields

old_table_fragments: TableFragments

new_table_fragments: TableFragments

merge_updates: Vec<MergeUpdate>

dispatchers: HashMap<ActorId, Vec<Dispatcher>>

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 table fragments id of new table fragment

Implementations

impl ReplaceTablePlan

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

Trait Implementations

impl Clone for ReplaceTablePlan

fn clone(&self) -> ReplaceTablePlan

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for ReplaceTablePlan

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

Formats the value using the given formatter.