dbsp 0.287.0

Continuous streaming analytics engine
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14

use crate::{
    OutputHandle,
    trace::{Batch, merge_batches},
};

impl<T> OutputHandle<T>
where
    T: Batch<Time = ()> + Send,
{
    /// See [`OutputHandle::consolidate`].
    pub fn dyn_consolidate(&self, factories: &T::Factories) -> T {
        merge_batches(factories, self.take_from_all(), &None, &None)
    }
}