Struct LabelledScope 

pub struct LabelledScope<G> {
    label: String,
    inner: G,
}

A wrapper around a timely Scope that that sets its name as a profiling label before scheduling its child operators.

Fields

label: String

Label value to set when an operator is scheduled.

inner: G

The inner scope.

Implementations

impl<'a, G, T> LabelledScope<Child<'a, G, T>>

where G: ScopeParent, T: Timestamp + Refines<G::Timestamp>,

pub fn parent(&self) -> &G

A reference of the child’s parent scope.

Trait Implementations

impl<G: AsWorker> AsWorker for LabelledScope<G>

fn config(&self) -> &WorkerConfig

Returns the worker configuration parameters.

fn index(&self) -> usize

Index of the worker among its peers.

fn peers(&self) -> usize

Number of peer workers.

fn allocate<T: Exchangeable>( &mut self, identifier: usize, address: Rc<[usize]>, ) -> (Vec<Box<dyn Push<T>>>, Box<dyn Pull<T>>)

Allocates a new channel from a supplied identifier and address.

fn pipeline<T: 'static>( &mut self, identifier: usize, address: Rc<[usize]>, ) -> (ThreadPusher<T>, ThreadPuller<T>)

Constructs a pipeline channel from the worker to itself.

fn broadcast<T: Exchangeable + Clone>( &mut self, identifier: usize, address: Rc<[usize]>, ) -> (Box<dyn Push<T>>, Box<dyn Pull<T>>)

Allocates a broadcast channel, where each pushed message is received by all.

fn new_identifier(&mut self) -> usize

Allocates a new worker-unique identifier.

fn peek_identifier(&self) -> usize

The next worker-unique identifier to be allocated.

fn log_register(&self) -> Option<RefMut<'_, Registry>>

Provides access to named logging streams.

fn logger_for<CB: ContainerBuilder>(&self, name: &str) -> Option<Logger<CB>>

Acquires a logger by name, if the log register exists and the name is registered.

fn logging(&self) -> Option<TimelyLogger>

Provides access to the timely logging stream.

impl<G: Clone> Clone for LabelledScope<G>

fn clone(&self) -> LabelledScope<G>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<G: Scheduler> Scheduler for LabelledScope<G>

fn activations(&self) -> Rc<RefCell<Activations>>

Provides a shared handle to the activation scheduler.

fn activator_for(&self, path: Rc<[usize]>) -> Activator

Constructs an Activator tied to the specified operator address.

fn sync_activator_for(&self, path: Vec<usize>) -> SyncActivator

Constructs a SyncActivator tied to the specified operator address.

impl<'a, G, T> Scope for LabelledScope<Child<'a, G, T>>

where G: ScopeParent, T: Timestamp + Refines<G::Timestamp>,

fn name(&self) -> String

A useful name describing the scope.

fn addr(&self) -> Rc<[usize]>

A sequence of scope identifiers describing the path from the worker root to this scope.

fn addr_for_child(&self, index: usize) -> Rc<[usize]>

A sequence of scope identifiers describing the path from the worker root to the child indicated by index.

fn add_edge(&self, source: Source, target: Target)

Connects a source of data with a target of the data. This only links the two for the purposes of tracking progress, rather than effect any data movement itself.

fn allocate_operator_index(&mut self) -> usize

Allocates a new scope-local operator index.

fn add_operator_with_indices( &mut self, operator: Box<dyn Operate<Self::Timestamp>>, local: usize, global: usize, )

Adds a child Operate to the builder’s scope using supplied indices.

fn scoped<T2, R, F>(&mut self, name: &str, func: F) -> R

where T2: Timestamp + Refines<<Self as ScopeParent>::Timestamp>, F: FnOnce(&mut Child<'_, Self, T2>) -> R,

Creates a dataflow subgraph.

fn add_operator(&mut self, operator: Box<dyn Operate<Self::Timestamp>>) -> usize

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, )

Adds a child Operate to the builder’s scope using a supplied index.

fn iterative<T, R, F>(&mut self, func: F) -> R

where T: Timestamp, F: FnOnce(&mut Child<'_, Self, Product<Self::Timestamp, T>>) -> R,

Creates a iterative dataflow subgraph.

fn region<R, F>(&mut self, func: F) -> R

where F: FnOnce(&mut Child<'_, Self, Self::Timestamp>) -> R,

Creates a dataflow region with the same timestamp.

fn region_named<R, F>(&mut self, name: &str, func: F) -> R

where F: FnOnce(&mut Child<'_, Self, Self::Timestamp>) -> R,

Creates a dataflow region with the same timestamp.

impl<G: ScopeParent> ScopeParent for LabelledScope<G>

type Timestamp = <G as ScopeParent>::Timestamp

The timestamp associated with data in this scope.