rust/greptimedb
1
0
Fork 0
mirror of https://github.com/GreptimeTeam/greptimedb.git synced 2026-01-04 12:22:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: insert batch missing semantic type (#499)

Browse Source
This commit is contained in:
Lei, Huang
2022-11-14 21:18:01 +08:00
committed by GitHub
parent 508f4cdfd0
commit 4e7efbbe7e
1 changed files with 11 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
src/frontend/src/table/insert.rs
View File

@@ -4,12 +4,14 @@ use std::sync::Arc;
use api::helper::ColumnDataTypeWrapper;
use api::v1::codec;
use api::v1::codec::InsertBatch;
use api::v1::column::SemanticType;
use api::v1::insert_expr;
use api::v1::insert_expr::Expr;
use api::v1::Column;
use api::v1::InsertExpr;
use api::v1::MutateResult;
use client::{Database, ObjectResult};
use datatypes::prelude::ConcreteDataType;
use snafu::ensure;
use snafu::OptionExt;
use snafu::ResultExt;
@@ -97,8 +99,17 @@ pub fn insert_request_to_insert_batch(insert: &InsertRequest) -> Result<InsertBa
.try_into()
.context(error::ColumnDataTypeSnafu)?;
// TODO(hl): need refactor
let semantic_type =
if vector.data_type() == ConcreteDataType::timestamp_millis_datatype() {
SemanticType::Timestamp
} else {
SemanticType::Field
};
let mut column = Column {
column_name: column_name.clone(),
semantic_type: semantic_type.into(),
datatype: datatype.datatype() as i32,
..Default::default()
};