Struct timely::progress::subgraph::Subgraph

pub struct Subgraph<TOuter, TInner>
where
    TOuter: Timestamp,
    TInner: Timestamp + Refines<TOuter>,
{
    pub path: Rc<[usize]>,
    /* private fields */
}

A dataflow subgraph.

The subgraph type contains the infrastructure required to describe the topology of and track progress within a dataflow subgraph.

Fields

path: Rc<[usize]>

Path of identifiers from the root.

Trait Implementations

impl<TOuter, TInner> Operate<TOuter> for Subgraph<TOuter, TInner>

where TOuter: Timestamp, TInner: Timestamp + Refines<TOuter>,

fn local(&self) -> bool

Indicates if the operator is strictly local to this worker.

fn inputs(&self) -> usize

The number of inputs.

fn outputs(&self) -> usize

The number of outputs.

fn get_internal_summary( &mut self, ) -> (Vec<Vec<Antichain<TOuter::Summary>>>, Rc<RefCell<SharedProgress<TOuter>>>)

Fetches summary information about internal structure of the operator.

fn set_external_summary(&mut self)

Signals that external frontiers have been set.

fn notify_me(&self) -> bool

Indicates of whether the operator requires push_external_progress information or not.

impl<TOuter, TInner> Schedule for Subgraph<TOuter, TInner>

where TOuter: Timestamp, TInner: Timestamp + Refines<TOuter>,

fn name(&self) -> &str

A descriptive name for the operator

fn path(&self) -> &[usize]

An address identifying the operator.

fn schedule(&mut self) -> bool

Schedules the operator, receives “cannot terminate” boolean.