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<D: Container, P>( &mut self, stream: &StreamCore<G, D>, pact: P, ) -> P::Puller

where P: ParallelizationContractCore<G::Timestamp, D>,

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

pub fn new_input_connection<D: Container, P>( &mut self, stream: &StreamCore<G, D>, pact: P, connection: Vec<Antichain<<G::Timestamp as Timestamp>::Summary>>, ) -> P::Puller

where P: ParallelizationContractCore<G::Timestamp, D>,

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

pub fn new_output<D: Container>( &mut self, ) -> (TeeCore<G::Timestamp, D>, StreamCore<G, D>)

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

pub fn new_output_connection<D: Container>( &mut self, connection: Vec<Antichain<<G::Timestamp as Timestamp>::Summary>>, ) -> (TeeCore<G::Timestamp, D>, StreamCore<G, D>)

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.