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

Function identity_pipeline_inner

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