Trait Source 

pub trait Source: Send + Sync {
    // Required methods
    fn source_name(&self) -> &str;
    fn read_batch(
        &self,
        pipeline: &Pipeline,
        checkpoint: Option<&str>,
        context: &QueryContext,
    ) -> DataResult<PipelineBatch>;
}

Required Methods

fn source_name(&self) -> &str

fn read_batch( &self, pipeline: &Pipeline, checkpoint: Option<&str>, context: &QueryContext, ) -> DataResult<PipelineBatch>

Implementors

impl Source for FileJsonLineSource

impl Source for InMemoryRecordSource

impl Source for ObjectStoreJsonSource

impl<A: BigQueryAdapter + ?Sized + Send + Sync> Source for BigQueryPipelineSource<A>

impl<A: ClickHouseAdapter + ?Sized + Send + Sync> Source for ClickHousePipelineSource<A>

impl<A: OpenSearchAdapter + ?Sized + Send + Sync> Source for OpenSearchPipelineSource<A>

impl<A: SingleStoreAdapter + ?Sized + Send + Sync> Source for SingleStorePipelineSource<A>