Skip to content

Commit

Permalink
remove trim g
Browse files Browse the repository at this point in the history
  • Loading branch information
SkyFan2002 committed Sep 5, 2024
1 parent b95dfce commit d784fe3
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
1 change: 1 addition & 0 deletions Cargo.lock

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

5 changes: 2 additions & 3 deletions src/query/storages/fuse/src/io/locations.rs
Original file line number Diff line number Diff line change
Expand Up @@ -16,7 +16,6 @@ use std::marker::PhantomData;

use databend_common_exception::Result;
use databend_common_expression::DataBlock;
use databend_storages_common_table_meta::meta::trim_vacuum2_object_prefix;
use databend_storages_common_table_meta::meta::Location;
use databend_storages_common_table_meta::meta::SegmentInfo;
use databend_storages_common_table_meta::meta::SnapshotVersion;
Expand Down Expand Up @@ -172,7 +171,7 @@ impl TableMetaLocationGenerator {
let splits = loc.split('/').collect::<Vec<_>>();
let len = splits.len();
let prefix = splits[..len - 2].join("/");
let block_name = trim_vacuum2_object_prefix(splits[len - 1]);
let block_name = splits[len - 1];
format!("{prefix}/{FUSE_TBL_AGG_INDEX_PREFIX}/{index_id}/{block_name}")
}

Expand All @@ -184,7 +183,7 @@ impl TableMetaLocationGenerator {
let splits = loc.split('/').collect::<Vec<_>>();
let len = splits.len();
let prefix = splits[..len - 2].join("/");
let block_name = trim_vacuum2_object_prefix(splits[len - 1]);
let block_name = splits[len - 1];
let id: String = block_name.chars().take(32).collect();
let short_ver: String = index_version.chars().take(7).collect();
format!(
Expand Down

0 comments on commit d784fe3

Please sign in to comment.