Struct OperatorBuilder

pub struct OperatorBuilder<G: Scope> { /* private fields */ }

Builds operators with generic shape.

Implementations

impl<G: Scope> OperatorBuilder<G>

pub fn new(name: String, scope: G) -> Self

Allocates a new generic operator builder from its containing scope.

pub fn index(&self) -> usize

The operator’s scope-local index.

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 set_notify(&mut self, notify: bool)

Indicates whether the operator requires frontier information.

pub fn new_input<C: Container, P>( &mut self, stream: &StreamCore<G, C>, pact: P, ) -> P::Puller

where P: ParallelizationContract<G::Timestamp, 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: &StreamCore<G, C>, pact: P, connection: I, ) -> P::Puller

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

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

pub fn new_output<C: Container>( &mut self, ) -> (Tee<G::Timestamp, C>, StreamCore<G, 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, ) -> (Tee<G::Timestamp, C>, StreamCore<G, C>)

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

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

pub fn build<L>(self, logic: L)

where L: FnMut(&mut SharedProgress<G::Timestamp>) -> bool + 'static,

Creates an operator implementation from supplied logic constructor.

pub fn operator_info(&self) -> OperatorInfo

Information describing the operator.

Trait Implementations

impl<G: Debug + Scope> Debug for OperatorBuilder<G>

where G::Timestamp: Debug,

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

Formats the value using the given formatter.