Skip to content

Commit

Permalink
chore: remove unused method (#4703)
Browse files Browse the repository at this point in the history
  • Loading branch information
fengjiachun authored Sep 9, 2024
1 parent 04e7dd6 commit 545a80c
Show file tree
Hide file tree
Showing 2 changed files with 11 additions and 11 deletions.
20 changes: 10 additions & 10 deletions src/common/grpc-expr/src/insert.rs
Original file line number Diff line number Diff line change
Expand Up @@ -14,11 +14,10 @@

use api::helper;
use api::v1::column::Values;
use api::v1::{AddColumns, Column, CreateTableExpr};
use api::v1::{Column, CreateTableExpr};
use common_base::BitVec;
use datatypes::data_type::{ConcreteDataType, DataType};
use datatypes::prelude::VectorRef;
use datatypes::schema::SchemaRef;
use snafu::{ensure, ResultExt};
use table::metadata::TableId;
use table::table_reference::TableReference;
Expand All @@ -27,11 +26,6 @@ use crate::error::{CreateVectorSnafu, Result, UnexpectedValuesLengthSnafu};
use crate::util;
use crate::util::ColumnExpr;

pub fn find_new_columns(schema: &SchemaRef, columns: &[Column]) -> Result<Option<AddColumns>> {
let column_exprs = ColumnExpr::from_columns(columns);
util::extract_new_columns(schema, column_exprs)
}

/// Try to build create table request from insert data.
pub fn build_create_expr_from_insertion(
catalog_name: &str,
Expand Down Expand Up @@ -114,7 +108,6 @@ mod tests {
use super::*;
use crate::error;
use crate::error::ColumnDataTypeSnafu;
use crate::insert::find_new_columns;

#[inline]
fn build_column_schema(
Expand Down Expand Up @@ -281,11 +274,18 @@ mod tests {

let schema = Arc::new(SchemaBuilder::try_from(columns).unwrap().build().unwrap());

assert!(find_new_columns(&schema, &[]).unwrap().is_none());
assert!(
util::extract_new_columns(&schema, ColumnExpr::from_columns(&[]))
.unwrap()
.is_none()
);

let insert_batch = mock_insert_batch();

let add_columns = find_new_columns(&schema, &insert_batch.0).unwrap().unwrap();
let add_columns =
util::extract_new_columns(&schema, ColumnExpr::from_columns(&insert_batch.0))
.unwrap()
.unwrap();

assert_eq!(5, add_columns.add_columns.len());
let host_column = &add_columns.add_columns[0];
Expand Down
2 changes: 1 addition & 1 deletion src/common/grpc-expr/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -19,4 +19,4 @@ pub mod insert;
pub mod util;

pub use alter::{alter_expr_to_request, create_table_schema};
pub use insert::{build_create_expr_from_insertion, find_new_columns};
pub use insert::build_create_expr_from_insertion;

0 comments on commit 545a80c

Please sign in to comment.