pipeline::etl::transform::transformer::greptime

Function identity_pipeline_inner

Source 
fn identity_pipeline_inner(
    pipeline_maps: Vec<PipelineMap>,
    pipeline_ctx: &PipelineContext<'_>,
) -> Result<(SchemaInfo, Vec<Row>)>