Skip to content

Commit

Permalink
fixup! fixup! chore: upgrade to Datafusion 38
Browse files Browse the repository at this point in the history
  • Loading branch information
rtyler committed May 26, 2024
1 parent 2fc08ef commit 68382e7
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 4 deletions.
2 changes: 1 addition & 1 deletion crates/benchmarks/src/bin/merge.rs
Original file line number Diff line number Diff line change
Expand Up @@ -7,10 +7,10 @@ use arrow::datatypes::Schema as ArrowSchema;
use arrow_array::{RecordBatch, StringArray, UInt32Array};
use chrono::Duration;
use clap::{command, Args, Parser, Subcommand};
use datafusion::functions::expr_fn::random;
use datafusion::{datasource::MemTable, prelude::DataFrame};
use datafusion_common::DataFusionError;
use datafusion_expr::{cast, col, lit};
use datafusion::functions::expr_fn::random;
use deltalake_core::protocol::SaveMode;
use deltalake_core::{
arrow::{
Expand Down
5 changes: 2 additions & 3 deletions crates/sql/src/planner.rs
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
use std::sync::Arc;

use datafusion_common::{TableReference, Result as DFResult};
use datafusion_common::{Result as DFResult, TableReference};
use datafusion_expr::logical_plan::{Extension, LogicalPlan};
use datafusion_sql::planner::{
object_name_to_table_reference, ContextProvider, IdentNormalizer, ParserOptions, SqlToRel,
Expand Down Expand Up @@ -65,8 +65,7 @@ impl<'a, S: ContextProvider> DeltaSqlToRel<'a, S> {

fn describe_to_plan(&self, describe: DescribeStatement) -> DFResult<LogicalPlan> {
let table_ref = self.object_name_to_table_reference(describe.table)?;
let plan =
DeltaStatement::DescribeFiles(DescribeFiles::new(table_ref.clone()));
let plan = DeltaStatement::DescribeFiles(DescribeFiles::new(table_ref.clone()));
Ok(LogicalPlan::Extension(Extension {
node: Arc::new(plan),
}))
Expand Down

0 comments on commit 68382e7

Please sign in to comment.