Skip to main content

identity_pipeline_inner

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

Function identity_pipeline_inner 

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