Skip to main content

Encoder

feldera_adapterlib::format

Trait Encoder 

Source 
pub trait Encoder: Send {
    // Required methods
    fn consumer(&mut self) -> &mut dyn OutputConsumer;
    fn encode(&mut self, batch: Arc<dyn SerBatchReader>) -> AnyResult<()>;
}

Required Methods§

Source

fn consumer(&mut self) -> &mut dyn OutputConsumer

Returns a reference to the consumer that the encoder is connected to.

Source

fn encode(&mut self, batch: Arc<dyn SerBatchReader>) -> AnyResult<()>

Encode a batch of updates, push encoded buffers to the consumer using [OutputConsumer::push_buffer].

Implementors§