Struct UnorderedHandle

pub struct UnorderedHandle<T: Timestamp, CB: ContainerBuilder> { /* private fields */ }

A handle to an input StreamCore, used to introduce data to a timely dataflow computation.

Implementations

impl<T: Timestamp, CB: ContainerBuilder> UnorderedHandle<T, CB>

pub fn session_with_builder( &mut self, cap: ActivateCapability<T>, ) -> ActivateOnDrop<AutoflushSession<'_, T, CB, Counter<T, CB::Container, Tee<T, CB::Container>>>>

Allocates a new automatically flushing session based on the supplied capability.

impl<T: Timestamp, C: Container + Data> UnorderedHandle<T, CapacityContainerBuilder<C>>

pub fn session( &mut self, cap: ActivateCapability<T>, ) -> ActivateOnDrop<AutoflushSession<'_, T, CapacityContainerBuilder<C>, Counter<T, C, Tee<T, C>>>>

Allocates a new automatically flushing session based on the supplied capability.

Trait Implementations

impl<T: Debug + Timestamp, CB: Debug + ContainerBuilder> Debug for UnorderedHandle<T, CB>

where CB::Container: Debug,

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

Formats the value using the given formatter.