Type Alias StreamVec 

pub type StreamVec<'scope, T, D> = Stream<'scope, T, Vec<D>>;

A stream batching data in owning vectors.

Aliased Type

pub struct StreamVec<'scope, T, D> { /* private fields */ }

Trait Implementations

impl<T: Timestamp, D: ExchangeData + Clone> Broadcast<D> for StreamVec<'_, T, D>

fn broadcast(self) -> Self

Broadcast records to all workers.

impl<T: Timestamp, D: 'static> Filter<D> for StreamVec<'_, T, D>

fn filter<P: FnMut(&D) -> bool + 'static>(self, predicate: P) -> Self

Returns a new instance of self containing only records satisfying predicate.

impl<'scope, T: Timestamp, D: 'static> Map<'scope, T, D> for StreamVec<'scope, T, D>

fn map_in_place<L: FnMut(&mut D) + 'static>( self, logic: L, ) -> StreamVec<'scope, T, D>

Updates each element of the stream and yields the element, re-using memory where possible.

fn flat_map<I: IntoIterator, L: FnMut(D) -> I + 'static>( self, logic: L, ) -> StreamVec<'scope, T, I::Item>

where I::Item: 'static,

Consumes each element of the stream and yields some number of new elements.

fn map<D2: 'static, L: FnMut(D) -> D2 + 'static>( self, logic: L, ) -> StreamVec<'scope, T, D2>

Consumes each element of the stream and yields a new element.

impl<'scope, T: Timestamp, D: 'static> Partition<'scope, T, D> for StreamVec<'scope, T, D>

fn partition<D2: 'static, F: Fn(D) -> (u64, D2) + 'static>( self, parts: u64, route: F, ) -> Vec<StreamVec<'scope, T, D2>>

Produces parts output streams, containing records produced and assigned by route.