Skip to main content

Transform

shelly_data

Trait Transform 

Source 
pub trait Transform: Send + Sync {
    // Required methods
    fn transform_name(&self) -> &str;
    fn transform_batch(
        &self,
        pipeline: &Pipeline,
        run: &PipelineRun,
        records: Vec<Row>,
        context: &QueryContext,
    ) -> DataResult<TransformBatch>;
}

Required Methods§

Source

fn transform_name(&self) -> &str

Source

fn transform_batch( &self, pipeline: &Pipeline, run: &PipelineRun, records: Vec<Row>, context: &QueryContext, ) -> DataResult<TransformBatch>

Implementors§