pub type RowErrBatcher<T, R> = MergeBatcher<Vec<((Row, DataflowError), T, R)>, ColumnationChunker<((Row, DataflowError), T, R)>, ColMerger<(Row, DataflowError), T, R>>;
Aliased Type§
struct RowErrBatcher<T, R> { /* private fields */ }
Trait Implementations
Source§impl<Input, C, M> Batcher for MergeBatcher<Input, C, M>where
C: ContainerBuilder<Container = <M as Merger>::Chunk> + Default + for<'a> PushInto<&'a mut Input>,
M: Merger,
<M as Merger>::Time: Timestamp,
impl<Input, C, M> Batcher for MergeBatcher<Input, C, M>where
C: ContainerBuilder<Container = <M as Merger>::Chunk> + Default + for<'a> PushInto<&'a mut Input>,
M: Merger,
<M as Merger>::Time: Timestamp,
Source§fn push_container(&mut self, container: &mut Input)
fn push_container(&mut self, container: &mut Input)
Push a container of data into this merge batcher. Updates the internal chain structure if needed.
Source§fn frontier(&mut self) -> AntichainRef<'_, <M as Merger>::Time>
fn frontier(&mut self) -> AntichainRef<'_, <M as Merger>::Time>
The frontier of elements remaining after the most recent call to self.seal
.
Source§fn new(
logger: Option<TypedLogger<CapacityContainerBuilder<Vec<(Duration, DifferentialEvent)>>, DifferentialEvent>>,
operator_id: usize,
) -> MergeBatcher<Input, C, M>
fn new( logger: Option<TypedLogger<CapacityContainerBuilder<Vec<(Duration, DifferentialEvent)>>, DifferentialEvent>>, operator_id: usize, ) -> MergeBatcher<Input, C, M>
Allocates a new empty batcher.