[−][src]Struct timely::dataflow::scopes::child::Child
A Child
wraps a Subgraph
and a parent G: Scope
. It manages the addition
of Operate
s to a subgraph, and the connection of edges between them.
Fields
subgraph: &'a RefCell<SubgraphBuilder<G::Timestamp, T>>
The subgraph under assembly.
parent: G
A copy of the child's parent scope.
logging: Option<Logger>
The log writer for this scope.
Methods
impl<'a, G, T> Child<'a, G, T> where
G: ScopeParent,
T: Timestamp + Refines<G::Timestamp>,
[src]
G: ScopeParent,
T: Timestamp + Refines<G::Timestamp>,
pub fn index(&self) -> usize
[src]
This worker's unique identifier.
Ranges from 0
to self.peers() - 1
.
pub fn peers(&self) -> usize
[src]
The total number of workers in the computation.
Trait Implementations
impl<'a, G, T> AsWorker for Child<'a, G, T> where
G: ScopeParent,
T: Timestamp + Refines<G::Timestamp>,
[src]
G: ScopeParent,
T: Timestamp + Refines<G::Timestamp>,
fn index(&self) -> usize
[src]
fn peers(&self) -> usize
[src]
fn allocate<D: Data>(
&mut self,
identifier: usize,
address: &[usize]
) -> (Vec<Box<dyn Push<Message<D>>>>, Box<dyn Pull<Message<D>>>)
[src]
&mut self,
identifier: usize,
address: &[usize]
) -> (Vec<Box<dyn Push<Message<D>>>>, Box<dyn Pull<Message<D>>>)
fn pipeline<D: 'static>(
&mut self,
identifier: usize,
address: &[usize]
) -> (ThreadPusher<Message<D>>, ThreadPuller<Message<D>>)
[src]
&mut self,
identifier: usize,
address: &[usize]
) -> (ThreadPusher<Message<D>>, ThreadPuller<Message<D>>)
fn new_identifier(&mut self) -> usize
[src]
fn log_register(&self) -> RefMut<Registry<WorkerIdentifier>>
[src]
fn logging(&self) -> Option<TimelyLogger>
[src]
Provides access to the timely logging stream.
impl<'a, G, T> ScopeParent for Child<'a, G, T> where
G: ScopeParent,
T: Timestamp + Refines<G::Timestamp>,
[src]
G: ScopeParent,
T: Timestamp + Refines<G::Timestamp>,
type Timestamp = T
The timestamp associated with data in this scope.
impl<'a, G, T> Scope for Child<'a, G, T> where
G: ScopeParent,
T: Timestamp + Refines<G::Timestamp>,
[src]
G: ScopeParent,
T: Timestamp + Refines<G::Timestamp>,
fn name(&self) -> String
[src]
fn addr(&self) -> Vec<usize>
[src]
fn add_edge(&self, source: Source, target: Target)
[src]
fn add_operator_with_indices(
&mut self,
operator: Box<dyn Operate<Self::Timestamp>>,
local: usize,
global: usize
)
[src]
&mut self,
operator: Box<dyn Operate<Self::Timestamp>>,
local: usize,
global: usize
)
fn allocate_operator_index(&mut self) -> usize
[src]
fn scoped<T2, R, F>(&mut self, name: &str, func: F) -> R where
T2: Timestamp + Refines<T>,
F: FnOnce(&mut Child<Self, T2>) -> R,
[src]
T2: Timestamp + Refines<T>,
F: FnOnce(&mut Child<Self, T2>) -> R,
fn add_operator(&mut self, operator: Box<dyn Operate<Self::Timestamp>>) -> usize
[src]
Adds a child Operate
to the builder's scope. Returns the new child's index.
fn add_operator_with_index(
&mut self,
operator: Box<dyn Operate<Self::Timestamp>>,
index: usize
)
[src]
&mut self,
operator: Box<dyn Operate<Self::Timestamp>>,
index: usize
)
Adds a child Operate
to the builder's scope using a supplied index. Read more
fn iterative<T, R, F>(&mut self, func: F) -> R where
T: Timestamp,
F: FnOnce(&mut Child<Self, Product<Self::Timestamp, T>>) -> R,
[src]
T: Timestamp,
F: FnOnce(&mut Child<Self, Product<Self::Timestamp, T>>) -> R,
Creates a iterative dataflow subgraph. Read more
fn region<R, F>(&mut self, func: F) -> R where
F: FnOnce(&mut Child<Self, Self::Timestamp>) -> R,
[src]
F: FnOnce(&mut Child<Self, Self::Timestamp>) -> R,
Creates a dataflow region with the same timestamp. Read more
impl<'a, G, T> Scheduler for Child<'a, G, T> where
G: ScopeParent,
T: Timestamp + Refines<G::Timestamp>,
[src]
G: ScopeParent,
T: Timestamp + Refines<G::Timestamp>,
fn activations(&self) -> Rc<RefCell<Activations>>
[src]
fn activator_for(&self, path: &[usize]) -> Activator
[src]
impl<'a, G, T> Clone for Child<'a, G, T> where
G: ScopeParent,
T: Timestamp + Refines<G::Timestamp>,
[src]
G: ScopeParent,
T: Timestamp + Refines<G::Timestamp>,
Auto Trait Implementations
Blanket Implementations
impl<G> Input for G where
G: Scope,
<G as ScopeParent>::Timestamp: TotalOrder,
[src]
G: Scope,
<G as ScopeParent>::Timestamp: TotalOrder,
fn new_input<D>(
&mut Self
) -> (Handle<<G as ScopeParent>::Timestamp, D>, Stream<G, D>) where
D: Data,
[src]
&mut Self
) -> (Handle<<G as ScopeParent>::Timestamp, D>, Stream<G, D>) where
D: Data,
fn input_from<D>(
&mut Self,
&mut Handle<<G as ScopeParent>::Timestamp, D>
) -> Stream<G, D> where
D: Data,
[src]
&mut Self,
&mut Handle<<G as ScopeParent>::Timestamp, D>
) -> Stream<G, D> where
D: Data,
impl<G> UnorderedInput for G where
G: Scope,
[src]
G: Scope,
fn new_unordered_input<D>(
&mut Self
) -> ((UnorderedHandle<<G as ScopeParent>::Timestamp, D>, ActivateCapability<<G as ScopeParent>::Timestamp>), Stream<G, D>) where
D: Data,
[src]
&mut Self
) -> ((UnorderedHandle<<G as ScopeParent>::Timestamp, D>, ActivateCapability<<G as ScopeParent>::Timestamp>), Stream<G, D>) where
D: Data,
impl<G> Feedback for G where
G: Scope,
[src]
G: Scope,
fn feedback<D>(
&mut Self,
<<G as ScopeParent>::Timestamp as Timestamp>::Summary
) -> (Handle<G, D>, Stream<G, D>) where
D: Data,
[src]
&mut Self,
<<G as ScopeParent>::Timestamp as Timestamp>::Summary
) -> (Handle<G, D>, Stream<G, D>) where
D: Data,
impl<G, D> Concatenate for G where
D: Data,
G: Scope,
[src]
D: Data,
G: Scope,
fn concatenate<impl IntoIterator- >>(
&Self,
impl IntoIterator- >
) -> Stream<G, D> where
impl IntoIterator- >: IntoIterator<Item = Stream<G, D>>,
[src]
&Self,
impl IntoIterator
) -> Stream<G, D> where
impl IntoIterator
impl<T> Data for T where
T: 'static + Clone,
[src]
T: 'static + Clone,
impl<T, U> Into for T where
U: From<T>,
[src]
U: From<T>,
impl<T> ToOwned for T where
T: Clone,
[src]
T: Clone,
impl<T> From for T
[src]
impl<T, U> TryFrom for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T> Borrow for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> BorrowMut for T where
T: ?Sized,
[src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
[src]
impl<T, U> TryInto for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,