Trait Sink

Source

pub trait Sink: Send + Sync {
    // Required methods
    fn sink(
        &mut self,
        context: &PExecutionContext,
        chunk: DataChunk,
    ) -> PolarsResult<SinkResult>;
    fn combine(&mut self, other: &mut dyn Sink);
    fn split(&self, thread_no: usize) -> Box<dyn Sink>;
    fn finalize(
        &mut self,
        context: &PExecutionContext,
    ) -> PolarsResult<FinalizedSink>;
    fn as_any(&mut self) -> &mut dyn Any;
    fn fmt(&self) -> &str;

    // Provided methods
    fn is_join_build(&self) -> bool { ... }
    fn node(&self) -> Node { ... }
}