Trait Sink 

pub trait Sink: Send + Sync {
    // Required methods
    fn sink_name(&self) -> &str;
    fn write_batch(
        &self,
        pipeline: &Pipeline,
        run: &PipelineRun,
        records: &[Row],
        context: &QueryContext,
    ) -> DataResult<SinkWriteResult>;
}

Required Methods

fn sink_name(&self) -> &str

fn write_batch( &self, pipeline: &Pipeline, run: &PipelineRun, records: &[Row], context: &QueryContext, ) -> DataResult<SinkWriteResult>

Implementors

impl Sink for FileJsonLineSink

impl Sink for IdempotentInMemorySink

impl Sink for ObjectStoreJsonSink

impl<A: BigQueryAdapter + ?Sized + Send + Sync> Sink for BigQueryPipelineSink<A>

impl<A: ClickHouseAdapter + ?Sized + Send + Sync> Sink for ClickHousePipelineSink<A>

impl<A: OpenSearchAdapter + ?Sized + Send + Sync> Sink for OpenSearchPipelineSink<A>

impl<A: SingleStoreAdapter + ?Sized + Send + Sync> Sink for SingleStorePipelineSink<A>