pub fn identity_pipeline(
array: Vec<Value>,
table: Option<Arc<Table>>,
) -> Result<Rows>
Expand description
Identity pipeline for Greptime This pipeline will convert the input JSON array to Greptime Rows params table is used to set the semantic type of the row key column to Tag
- 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.