Function pipeline::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
- The pipeline will add a default timestamp column to the schema
- The pipeline not resolve NULL value
- The pipeline assumes that the json format is fixed
- The pipeline will return an error if the same column datatype is mismatched
- The pipeline will analyze the schema of each json record and merge them to get the final schema.