Trait SequentialConnection 

pub trait SequentialConnection: Connection {
    // Provided method
    fn delegate_to_committer_watermark<'life0, 'life1, 'async_trait>(
        &'life0 mut self,
        pipeline_task: &'life1 str,
        _checkpoint_hi_inclusive: Option<u64>,
    ) -> Pin<Box<dyn Future<Output = Result<Option<InitWatermark>>> + Send + 'async_trait>>
       where Self: Send + 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait { ... }
}

Extension of Connection for sequential pipeline operations.

Provided Methods

fn delegate_to_committer_watermark<'life0, 'life1, 'async_trait>( &'life0 mut self, pipeline_task: &'life1 str, _checkpoint_hi_inclusive: Option<u64>, ) -> Pin<Box<dyn Future<Output = Result<Option<InitWatermark>>> + Send + 'async_trait>>

where Self: Send + 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Helper to call in Connection::init_watermark impl that delegates to Connection::committer_watermark if impl does not attempt to write data.

Implementors