Skip to content

Commit

Permalink
fix clippy.
Browse files Browse the repository at this point in the history
  • Loading branch information
Rachelint committed Aug 14, 2023
1 parent b537829 commit 68af743
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 4 deletions.
6 changes: 3 additions & 3 deletions query_frontend/src/provider.rs
Original file line number Diff line number Diff line change
Expand Up @@ -97,7 +97,7 @@ fn enable_dedicated_partitioned_table_provider() -> bool {
}

impl ResolvedTable {
fn to_table_provider(self) -> Arc<dyn TableProvider> {
fn into_table_provider(self) -> Arc<dyn TableProvider> {
if self.table.partition_info().is_some() && enable_dedicated_partitioned_table_provider() {
let partition_info = self.table.partition_info().unwrap();
Arc::new(partition_table_engine::provider::TableProviderAdapter::new(
Expand Down Expand Up @@ -295,7 +295,7 @@ impl<'a, P: MetaProvider> ContextProviderAdapter<'a, P> {
}

pub fn table_source(&self, resolved_table: ResolvedTable) -> Arc<(dyn TableSource + 'static)> {
let table_provider = resolved_table.to_table_provider();
let table_provider = resolved_table.into_table_provider();

Arc::new(DefaultTableSource { table_provider })
}
Expand Down Expand Up @@ -435,7 +435,7 @@ impl SchemaProvider for SchemaProviderAdapter {

self.tables
.get(name_ref)
.map(|resolved| resolved.to_table_provider())
.map(|resolved| resolved.into_table_provider())
}

fn table_exist(&self, name: &str) -> bool {
Expand Down
2 changes: 1 addition & 1 deletion query_frontend/src/tests.rs
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@ use partition_table_engine::test_util::PartitionedMemoryTable;
use table_engine::{
memory::MemoryTable,
partition::{KeyPartitionInfo, PartitionDefinition, PartitionInfo},
table::{Table, TableId, TableRef},
table::{TableId, TableRef},
ANALYTIC_ENGINE_TYPE,
};

Expand Down

0 comments on commit 68af743

Please sign in to comment.