chore: rename

GreptimeTeam · Dec 19, 2024 · 07dbb13 · 07dbb13
1 parent d12f345
commit 07dbb13
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/src/flow/src/adapter/flownode_impl.rs b/src/flow/src/adapter/flownode_impl.rs
@@ -28,7 +28,7 @@ use itertools::Itertools;
 use snafu::{OptionExt, ResultExt};
 use store_api::storage::RegionId;
 
-use super::util::from_proto_to_column_schema;
+use super::util::from_proto_to_data_type;
 use crate::adapter::{CreateFlowArgs, FlowWorkerManager};
 use crate::error::InternalSnafu;
 use crate::metrics::METRIC_FLOW_TASK_COUNT;
@@ -209,7 +209,7 @@ impl Flownode for FlowWorkerManager {
                 .collect_vec();
             let batch_datatypes = insert_schema
                 .iter()
-                .map(from_proto_to_column_schema)
+                .map(from_proto_to_data_type)
                 .collect::<std::result::Result<Vec<_>, _>>()
                 .map_err(to_meta_err)?;
             self.handle_write_request(region_id.into(), rows, &batch_datatypes)

diff --git a/src/flow/src/adapter/util.rs b/src/flow/src/adapter/util.rs
@@ -23,7 +23,7 @@ use snafu::ResultExt;
 
 use crate::error::{Error, ExternalSnafu};
 
-pub fn from_proto_to_column_schema(
+pub fn from_proto_to_data_type(
     column_schema: &api::v1::ColumnSchema,
 ) -> Result<ConcreteDataType, Error> {
     let wrapper = ColumnDataTypeWrapper::try_new(