Struct timely::progress::subgraph::SubgraphBuilder

pub struct SubgraphBuilder<TOuter, TInner>
where
    TOuter: Timestamp,
    TInner: Timestamp,
{
    pub name: String,
    pub path: Rc<[usize]>,
    /* private fields */
}

A builder for interactively initializing a Subgraph.

This collects all the information necessary to get a Subgraph up and running, and is important largely through its build method which actually creates a Subgraph.

Fields

name: String

The name of this subgraph.

path: Rc<[usize]>

A sequence of integers uniquely identifying the subgraph.

Implementations

impl<TOuter, TInner> SubgraphBuilder<TOuter, TInner>

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

pub fn new_input( &mut self, shared_counts: Rc<RefCell<ChangeBatch<TInner>>>, ) -> Target

Allocates a new input to the subgraph and returns the target to that input in the outer graph.

pub fn new_output(&mut self) -> Source

Allocates a new output from the subgraph and returns the source of that output in the outer graph.

pub fn connect(&mut self, source: Source, target: Target)

Introduces a dependence from the source to the target.

This method does not effect data movement, but rather reveals to the progress tracking infrastructure that messages produced by source should be expected to be consumed at target.

pub fn new_from( path: Rc<[usize]>, logging: Option<Logger>, progress_logging: Option<ProgressLogger>, name: &str, ) -> SubgraphBuilder<TOuter, TInner>

Creates a SubgraphBuilder from a path of indexes from the dataflow root to the subgraph, terminating with the local index of the new subgraph itself.

pub fn allocate_child_id(&mut self) -> usize

Allocates a new child identifier, for later use.

pub fn add_child( &mut self, child: Box<dyn Operate<TInner>>, index: usize, identifier: usize, )

Adds a new child to the subgraph.

pub fn build<A: AsWorker>(self, worker: &mut A) -> Subgraph<TOuter, TInner>

Now that initialization is complete, actually build a subgraph.