pub trait RemapHandleReader {
    type FromTime: Timestamp;
    type IntoTime: Timestamp;

    // Required method
    fn next<'life0, 'async_trait>(
        &'life0 mut self,
    ) -> Pin<Box<dyn Future<Output = Option<(Vec<(Self::FromTime, Self::IntoTime, Diff)>, Antichain<Self::IntoTime>)>> + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
}
Expand description

A handle that can produce the data expressing the translation of FromTime to IntoTime.

This trait is a subtrait of RemapHandle so it can be shared between the primary reclocking implementation and remap collection migrations.

Required Associated Types§

Required Methods§

source

fn next<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Option<(Vec<(Self::FromTime, Self::IntoTime, Diff)>, Antichain<Self::IntoTime>)>> + 'async_trait>>
where Self: 'async_trait, 'life0: 'async_trait,

Produces the next batch of data contained in the remap collection and the upper frontier of that batch. The return batch should contain all the updates that happened at times not beyond ther returned upper.

Implementors§