Struct OperatorBuilder 

pub struct OperatorBuilder<'scope, T: Timestamp> { /* private fields */ }

Builds operators with generic shape.

Implementations

impl<'scope, T: Timestamp> OperatorBuilder<'scope, T>

pub fn new(name: String, scope: Scope<'scope, T>) -> Self

Allocates a new generic operator builder from its containing scope.

pub fn set_notify_for(&mut self, input: usize, notify: FrontierInterest)

Sets frontier interest for a specific input.

pub fn new_input<C: Container, P>( &mut self, stream: Stream<'scope, T, C>, pact: P, ) -> InputHandleCore<T, C, P::Puller>

where P: ParallelizationContract<T, C>,

Adds a new input to a generic operator builder, returning the Pull implementor to use.

pub fn new_input_connection<C: Container, P, I>( &mut self, stream: Stream<'scope, T, C>, pact: P, connection: I, ) -> InputHandleCore<T, C, P::Puller>

where P: ParallelizationContract<T, C>, I: IntoIterator<Item = (usize, Antichain<<T as Timestamp>::Summary>)> + Clone,

Adds a new input with connection information to a generic operator builder, returning the Pull implementor to use.

The connection parameter contains promises made by the operator for each of the existing outputs, that any timestamp appearing at the input, any output timestamp will be greater than or equal to the input timestamp subjected to a Summary greater or equal to some element of the corresponding antichain in connection.

Commonly the connections are either the unit summary, indicating the same timestamp might be produced as output, or an empty antichain indicating that there is no connection from the input to the output.

pub fn new_output<C: Container>( &mut self, ) -> (Output<T, C>, Stream<'scope, T, C>)

Adds a new output to a generic operator builder, returning the Push implementor to use.

pub fn new_output_connection<C: Container, I>( &mut self, connection: I, ) -> (Output<T, C>, Stream<'scope, T, C>)

where I: IntoIterator<Item = (usize, Antichain<<T as Timestamp>::Summary>)> + Clone,

Adds a new output with connection information to a generic operator builder, returning the Push implementor to use.

The connection parameter contains promises made by the operator for each of the existing inputs, that any timestamp appearing at the input, any output timestamp will be greater than or equal to the input timestamp subjected to a Summary greater or equal to some element of the corresponding antichain in connection.

Commonly the connections are either the unit summary, indicating the same timestamp might be produced as output, or an empty antichain indicating that there is no connection from the input to the output.

pub fn build<B, L>(self, constructor: B)

where B: FnOnce(Vec<Capability<T>>) -> L, L: FnMut(&[MutableAntichain<T>]) + 'static,

Creates an operator implementation from supplied logic constructor.

pub fn build_reschedule<B, L>(self, constructor: B)

where B: FnOnce(Vec<Capability<T>>) -> L, L: FnMut(&[MutableAntichain<T>]) -> bool + 'static,

Creates an operator implementation from supplied logic constructor.

Unlike build, the supplied closure can indicate if the operator should be considered incomplete. A not-incomplete operator will be shut down if it has empty input frontiers and holds no capabilities. Flagging oneself as incomplete is most commonly used by operators that manage external resources like file writes or transactions that must complete before the operator should be shut down.

This method boxes B and L and delegates to [build_reschedule_boxed]. For the fully generic (non-boxing) path, see [build_reschedule_typed].

pub fn build_reschedule_boxed<'a>( self, constructor: Box<dyn FnOnce(Vec<Capability<T>>) -> Box<dyn FnMut(&[MutableAntichain<T>]) -> bool> + 'a>, )

Like build_reschedule, but with a pre-boxed constructor.

This method exists primarily to force the Box<dyn ...> coercions, which can otherwise easily be Box<B> or Box<L> for specialized B and L instead.

pub fn build_reschedule_typed<B, L>(self, constructor: B)

where B: FnOnce(Vec<Capability<T>>) -> L, L: FnMut(&[MutableAntichain<T>]) -> bool + 'static,

Like build_reschedule, but specialized to the closure types B and L.

This method is instantiated once per distinct (B, L) pair, and one should be mindful of monomorphization bloat. Callers with many closures should consider erasing their variation, for example via Box<dyn ...>.

This method calls build_typed directly using a new closure, mirroring the variation in L, rather than forcing it to be reboxed via build.

pub fn index(&self) -> usize

Get the identifier assigned to the operator being constructed

pub fn global(&self) -> usize

The operator’s worker-unique identifier.

pub fn shape(&self) -> &OperatorShape

Return a reference to the operator’s shape

pub fn operator_info(&self) -> OperatorInfo

Creates operator info for the operator.

Trait Implementations

impl<'scope, T: Debug + Timestamp> Debug for OperatorBuilder<'scope, T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.