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

Function identity_pipeline_inner

Source 
fn identity_pipeline_inner(
    array: Vec<PipelineMap>,
    custom_ts: Option<&IdentityTimeIndex>,
) -> Result<(SchemaInfo, Vec<Row>)>