Struct StreamJobFragmentsToCreate 

pub struct StreamJobFragmentsToCreate {
    pub inner: StreamJobFragments,
    pub downstreams: FragmentDownstreamRelation,
}

Fields

inner: StreamJobFragments

downstreams: FragmentDownstreamRelation

Methods from Deref<Target = StreamJobFragments>

pub(super) fn new_fragment_info<'a>( &'a self, assignment: &'a SplitAssignment, ) -> impl Iterator<Item = (FragmentId, InflightFragmentInfo)> + 'a

pub fn to_protobuf( &self, fragment_upstreams: &HashMap<FragmentId, HashSet<FragmentId>>, fragment_dispatchers: &FragmentActorDispatchers, ) -> PbTableFragments

pub fn fragment_ids(&self) -> impl Iterator<Item = FragmentId> + '_

pub fn fragments(&self) -> impl Iterator<Item = &Fragment>

pub fn fragment_actors(&self, fragment_id: FragmentId) -> &[StreamActor]

pub fn stream_job_id(&self) -> TableId

Returns the table id.

pub fn timezone(&self) -> Option<String>

Returns the timezone of the table

pub fn is_created(&self) -> bool

Returns whether the table fragments is in Created state.

pub fn actor_ids(&self) -> Vec<ActorId>

Returns actor ids associated with this table.

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

pub fn tracking_progress_actor_ids( &self, ) -> Vec<(ActorId, BackfillUpstreamType)>

pub fn root_fragment(&self) -> Option<Fragment>

pub fn mview_fragment(&self) -> Option<Fragment>

Returns the fragment with the Mview type flag.

pub fn source_fragment(&self) -> Option<Fragment>

pub fn sink_fragment(&self) -> Option<Fragment>

pub fn stream_source_fragments(&self) -> HashMap<SourceId, BTreeSet<FragmentId>>

Extract the fragments that include source executors that contains an external stream source, grouping by source id.

pub fn source_backfill_fragments( &self, ) -> HashMap<SourceId, BTreeSet<(FragmentId, FragmentId)>>

pub fn upstream_table_counts(&self) -> HashMap<TableId, usize>

pub fn worker_actor_states( &self, ) -> BTreeMap<WorkerId, Vec<(ActorId, ActorState)>>

Returns states of actors group by worker id.

pub fn worker_actor_ids(&self) -> BTreeMap<WorkerId, Vec<ActorId>>

Returns actor locations group by worker id.

pub fn active_actors(&self) -> Vec<StreamActor>

Returns the status of actors group by worker id.

pub fn actors_to_create( &self, ) -> impl Iterator<Item = (FragmentId, &StreamNode, impl Iterator<Item = (&StreamActor, WorkerId)> + '_)> + '_

pub fn mv_table_id(&self) -> Option<u32>

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

Returns the internal table ids without the mview table.

pub fn all_table_ids(&self) -> impl Iterator<Item = u32> + '_

Returns all internal table ids including the mview table.

Trait Implementations

impl Clone for StreamJobFragmentsToCreate

fn clone(&self) -> StreamJobFragmentsToCreate

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StreamJobFragmentsToCreate

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

Formats the value using the given formatter.

impl Deref for StreamJobFragmentsToCreate

type Target = StreamJobFragments

The resulting type after dereferencing.

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

Dereferences the value.