diff --git a/crates/core/src/table/fs_view.rs b/crates/core/src/table/fs_view.rs index 63aa2fda..5210ccdd 100644 --- a/crates/core/src/table/fs_view.rs +++ b/crates/core/src/table/fs_view.rs @@ -86,7 +86,7 @@ impl FileSystemView { Ok(partition_paths .into_iter() .filter(|path_str| { - let partitions = path_str + let partitions: Vec = path_str .split('/') .map(|s| HudiTablePartition::try_from((s, &field_data_type)).unwrap()) .collect(); diff --git a/crates/core/src/table/mod.rs b/crates/core/src/table/mod.rs index 33124aa9..13005a86 100644 --- a/crates/core/src/table/mod.rs +++ b/crates/core/src/table/mod.rs @@ -39,11 +39,11 @@ use crate::config::read::HudiReadConfig::AsOfTimestamp; use crate::config::table::HudiTableConfig::{IsHiveStylePartitioning, PartitionFields}; use crate::config::table::{HudiTableConfig, TableTypeValue}; use crate::config::HudiConfigs; -use crate::file_group::{FileGroup, FileSlice}; +use crate::file_group::FileSlice; use crate::storage::utils::{empty_options, parse_uri}; use crate::storage::Storage; use crate::table::fs_view::FileSystemView; -use crate::table::partitions::{HudiTablePartition, PartitionFilter}; +use crate::table::partitions::PartitionFilter; use crate::table::timeline::Timeline; mod fs_view; @@ -217,7 +217,7 @@ impl Table { .fields .into_iter() .filter(|col| partition_set.contains(col.name())) - .map(|col| col.clone()) + .cloned() .collect(); Ok(Schema::new(Fields::from(partition_fields))) } diff --git a/crates/core/src/table/partitions.rs b/crates/core/src/table/partitions.rs index a5719842..46ba4e3a 100644 --- a/crates/core/src/table/partitions.rs +++ b/crates/core/src/table/partitions.rs @@ -76,7 +76,7 @@ impl PartitionFilter { /// Indicates if one of the HudiTable partition among the list /// matches with the partition filter. - pub fn match_partitions(&self, partitions: &Vec) -> bool { + pub fn match_partitions(&self, partitions: &[HudiTablePartition]) -> bool { partitions .iter() .any(|partition| self.match_partition(partition))