risingwave_connector::sink::log_store

Trait LogReaderExt

source
pub trait LogReaderExt
where Self: LogReader,
{ // Required methods fn transform_chunk<F: Fn(StreamChunk) -> StreamChunk + Sized>( self, _: F, ) -> TransformChunkLogReader<F, Self>; fn monitored(self, _: LogReaderMetrics) -> impl LogReader; }

Required Methods§

Object Safety§

This trait is not object safe.

Implementors§

source§

impl<T> LogReaderExt for T
where T: LogReader,