pub struct Subgraph<TOuter, TInner>{
pub path: Vec<usize>,
/* private fields */
}
Expand description
A dataflow subgraph.
The subgraph type contains the infrastructure required to describe the topology of and track progress within a dataflow subgraph.
Fields§
§path: Vec<usize>
Path of identifiers from the root.
Trait Implementations§
source§impl<TOuter, TInner> Operate<TOuter> for Subgraph<TOuter, TInner>
impl<TOuter, TInner> Operate<TOuter> for Subgraph<TOuter, TInner>
source§fn get_internal_summary(
&mut self
) -> (Vec<Vec<Antichain<TOuter::Summary>>>, Rc<RefCell<SharedProgress<TOuter>>>)
fn get_internal_summary( &mut self ) -> (Vec<Vec<Antichain<TOuter::Summary>>>, Rc<RefCell<SharedProgress<TOuter>>>)
Fetches summary information about internal structure of the operator. Read more
source§fn set_external_summary(&mut self)
fn set_external_summary(&mut self)
Signals that external frontiers have been set. Read more
Auto Trait Implementations§
impl<TOuter, TInner> Freeze for Subgraph<TOuter, TInner>
impl<TOuter, TInner> !RefUnwindSafe for Subgraph<TOuter, TInner>
impl<TOuter, TInner> !Send for Subgraph<TOuter, TInner>
impl<TOuter, TInner> !Sync for Subgraph<TOuter, TInner>
impl<TOuter, TInner> Unpin for Subgraph<TOuter, TInner>
impl<TOuter, TInner> !UnwindSafe for Subgraph<TOuter, TInner>
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
source§impl<R, O, T> CopyOnto<ConsecutiveOffsetPairs<R, O>> for T
impl<R, O, T> CopyOnto<ConsecutiveOffsetPairs<R, O>> for T
source§fn copy_onto(
self,
target: &mut ConsecutiveOffsetPairs<R, O>
) -> <ConsecutiveOffsetPairs<R, O> as Region>::Index
fn copy_onto( self, target: &mut ConsecutiveOffsetPairs<R, O> ) -> <ConsecutiveOffsetPairs<R, O> as Region>::Index
Copy self into the target container, returning an index that allows to
look up the corresponding read item.