Trait mz_storage_client::util::remap_handle::RemapHandleReader

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;
}

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

type FromTime: Timestamp

type IntoTime: Timestamp

Required Methods

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