pub trait Sink: Send + Sync {
// Required methods
fn consume(&mut self, chunk: DataChunk) -> Result<bool, OperatorError>;
fn finalize(&mut self) -> Result<(), OperatorError>;
fn name(&self) -> &'static str;
}Expand description
Sink that receives output from operators.
Sinks consume data chunks produced by the pipeline.
Required Methods§
Sourcefn consume(&mut self, chunk: DataChunk) -> Result<bool, OperatorError>
fn consume(&mut self, chunk: DataChunk) -> Result<bool, OperatorError>
Consume a chunk of data.
Returns Ok(true) to continue, Ok(false) to signal early termination.
Sourcefn finalize(&mut self) -> Result<(), OperatorError>
fn finalize(&mut self) -> Result<(), OperatorError>
Called when all input has been processed.