differential_dataflow::logging

Type Alias DifferentialEventBuilder

Source
pub type DifferentialEventBuilder = CapacityContainerBuilder<Vec<(Duration, DifferentialEvent)>>;
Expand description

Container builder for differential log events.

Aliased Type§

struct DifferentialEventBuilder { /* private fields */ }

Trait Implementations

Source§

impl<C> ContainerBuilder for CapacityContainerBuilder<C>
where C: Container + Clone + 'static,

Source§

type Container = C

The container type we’re building.
Source§

fn extract(&mut self) -> Option<&mut C>

Extract assembled containers, potentially leaving unfinished data behind. Can be called repeatedly, for example while the caller can send data. Read more
Source§

fn finish(&mut self) -> Option<&mut C>

Extract assembled containers and any unfinished data. Should be called repeatedly until it returns None.
Source§

fn partition<I>( container: &mut Self::Container, builders: &mut [Self], index: I, )
where Self: for<'a> PushInto<<Self::Container as Container>::Item<'a>>, I: for<'a> FnMut(&<Self::Container as Container>::Item<'a>) -> usize,

Partitions container among builders, using the function index to direct items.
Source§

impl<C> Debug for CapacityContainerBuilder<C>
where C: Debug,

Source§

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

Formats the value using the given formatter. Read more
Source§

impl<C> Default for CapacityContainerBuilder<C>
where C: Default,

Source§

fn default() -> CapacityContainerBuilder<C>

Returns the “default value” for a type. Read more
Source§

impl<T, C> PushInto<T> for CapacityContainerBuilder<C>
where C: SizableContainer + PushInto<T>,

Source§

fn push_into(&mut self, item: T)

Push item into self.
Source§

impl<C> LengthPreservingContainerBuilder for CapacityContainerBuilder<C>
where C: Container + Clone + 'static,