Function pipeline::etl::transform::transformer::greptime::identity_pipeline

source ยท 
pub fn identity_pipeline(array: Vec<Value>) -> Result<Rows>
Expand description

Identity pipeline for Greptime This pipeline will convert the input JSON array to Greptime Rows

  1. The pipeline will add a default timestamp column to the schema
  2. The pipeline not resolve NULL value
  3. The pipeline assumes that the json format is fixed
  4. The pipeline will return an error if the same column datatype is mismatched
  5. The pipeline will analyze the schema of each json record and merge them to get the final schema.