Struct timely::dataflow::operators::generic::builder_raw::OperatorBuilder [−][src]
Builds operators with generic shape.
Implementations
impl<G: Scope> OperatorBuilder<G>
[src]
pub fn new(name: String, scope: G) -> Self
[src]
Allocates a new generic operator builder from its containing scope.
pub fn index(&self) -> usize
[src]
The operator’s scope-local index.
pub fn global(&self) -> usize
[src]
The operator’s worker-unique identifier.
pub fn shape(&self) -> &OperatorShape
[src]
Return a reference to the operator’s shape
pub fn set_notify(&mut self, notify: bool)
[src]
Indicates whether the operator requires frontier information.
pub fn new_input<D: Data, P>(
&mut self,
stream: &Stream<G, D>,
pact: P
) -> P::Puller where
P: ParallelizationContract<G::Timestamp, D>,
[src]
&mut self,
stream: &Stream<G, D>,
pact: P
) -> P::Puller where
P: ParallelizationContract<G::Timestamp, D>,
Adds a new input to a generic operator builder, returning the Pull
implementor to use.
pub fn new_input_connection<D: Data, P>(
&mut self,
stream: &Stream<G, D>,
pact: P,
connection: Vec<Antichain<<G::Timestamp as Timestamp>::Summary>>
) -> P::Puller where
P: ParallelizationContract<G::Timestamp, D>,
[src]
&mut self,
stream: &Stream<G, D>,
pact: P,
connection: Vec<Antichain<<G::Timestamp as Timestamp>::Summary>>
) -> P::Puller where
P: ParallelizationContract<G::Timestamp, D>,
Adds a new input to a generic operator builder, returning the Pull
implementor to use.
pub fn new_output<D: Data>(&mut self) -> (Tee<G::Timestamp, D>, Stream<G, D>)
[src]
Adds a new output to a generic operator builder, returning the Push
implementor to use.
pub fn new_output_connection<D: Data>(
&mut self,
connection: Vec<Antichain<<G::Timestamp as Timestamp>::Summary>>
) -> (Tee<G::Timestamp, D>, Stream<G, D>)
[src]
&mut self,
connection: Vec<Antichain<<G::Timestamp as Timestamp>::Summary>>
) -> (Tee<G::Timestamp, D>, Stream<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,
[src]
L: FnMut(&mut SharedProgress<G::Timestamp>) -> bool + 'static,
Creates an operator implementation from supplied logic constructor.
pub fn operator_info(&self) -> OperatorInfo
[src]
Information describing the operator.
Auto Trait Implementations
impl<G> RefUnwindSafe for OperatorBuilder<G> where
G: RefUnwindSafe,
<<G as ScopeParent>::Timestamp as Timestamp>::Summary: RefUnwindSafe,
G: RefUnwindSafe,
<<G as ScopeParent>::Timestamp as Timestamp>::Summary: RefUnwindSafe,
impl<G> Send for OperatorBuilder<G> where
G: Send,
<<G as ScopeParent>::Timestamp as Timestamp>::Summary: Send,
G: Send,
<<G as ScopeParent>::Timestamp as Timestamp>::Summary: Send,
impl<G> Sync for OperatorBuilder<G> where
G: Sync,
<<G as ScopeParent>::Timestamp as Timestamp>::Summary: Sync,
G: Sync,
<<G as ScopeParent>::Timestamp as Timestamp>::Summary: Sync,
impl<G> Unpin for OperatorBuilder<G> where
G: Unpin,
<<G as ScopeParent>::Timestamp as Timestamp>::Summary: Unpin,
G: Unpin,
<<G as ScopeParent>::Timestamp as Timestamp>::Summary: Unpin,
impl<G> UnwindSafe for OperatorBuilder<G> where
G: UnwindSafe,
<<G as ScopeParent>::Timestamp as Timestamp>::Summary: UnwindSafe,
G: UnwindSafe,
<<G as ScopeParent>::Timestamp as Timestamp>::Summary: UnwindSafe,
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
pub fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> From<T> for T
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
pub fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,