Type Alias BoxWriter

pub type BoxWriter<CM> = Box<dyn SinkWriter<CommitMetadata = CM> + Send + 'static>;

Aliased Type

struct BoxWriter<CM>(/* private fields */);

Trait Implementations

impl<CM: 'static + Send> SinkWriter for BoxWriter<CM>

type CommitMetadata = CM

fn begin_epoch<'life0, 'async_trait>( &'life0 mut self, epoch: u64, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Begin a new epoch

fn write_batch<'life0, 'async_trait>( &'life0 mut self, chunk: StreamChunk, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Write a stream chunk to sink

fn barrier<'life0, 'async_trait>( &'life0 mut self, is_checkpoint: bool, ) -> Pin<Box<dyn Future<Output = Result<CM>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Receive a barrier and mark the end of current epoch. When is_checkpoint is true, the sink writer should commit the current epoch.

fn abort<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Clean up

fn update_vnode_bitmap<'life0, 'async_trait>( &'life0 mut self, vnode_bitmap: Arc<Bitmap>, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Update the vnode bitmap of current sink writer