Skip to content

Commit

Permalink
Upgrade to DataFusion 43 (apache#691)
Browse files Browse the repository at this point in the history
  • Loading branch information
gruuya authored and ZENOTME committed Nov 15, 2024
1 parent 81e80b0 commit e1f31c5
Show file tree
Hide file tree
Showing 5 changed files with 7 additions and 3 deletions.
4 changes: 2 additions & 2 deletions crates/integrations/datafusion/Cargo.toml
Original file line number Diff line number Diff line change
Expand Up @@ -23,15 +23,15 @@ homepage = { workspace = true }
rust-version = { workspace = true }

categories = ["database"]
description = "Apache Iceberg Datafusion Integration"
description = "Apache Iceberg DataFusion Integration"
repository = { workspace = true }
license = { workspace = true }
keywords = ["iceberg", "integrations", "datafusion"]

[dependencies]
anyhow = { workspace = true }
async-trait = { workspace = true }
datafusion = { version = "42" }
datafusion = { version = "43" }
futures = { workspace = true }
iceberg = { workspace = true }
tokio = { workspace = true }
Expand Down
1 change: 1 addition & 0 deletions crates/integrations/datafusion/src/catalog.rs
Original file line number Diff line number Diff line change
Expand Up @@ -30,6 +30,7 @@ use crate::schema::IcebergSchemaProvider;
///
/// Acts as a centralized catalog provider that aggregates
/// multiple [`SchemaProvider`], each associated with distinct namespaces.
#[derive(Debug)]
pub struct IcebergCatalogProvider {
/// A `HashMap` where keys are namespace names
/// and values are dynamic references to objects implementing the
Expand Down
1 change: 1 addition & 0 deletions crates/integrations/datafusion/src/schema.rs
Original file line number Diff line number Diff line change
Expand Up @@ -30,6 +30,7 @@ use crate::table::IcebergTableProvider;

/// Represents a [`SchemaProvider`] for the Iceberg [`Catalog`], managing
/// access to table providers within a specific namespace.
#[derive(Debug)]
pub(crate) struct IcebergSchemaProvider {
/// A `HashMap` where keys are table names
/// and values are dynamic references to objects implementing the
Expand Down
1 change: 1 addition & 0 deletions crates/integrations/datafusion/src/table/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -35,6 +35,7 @@ use crate::physical_plan::scan::IcebergTableScan;

/// Represents a [`TableProvider`] for the Iceberg [`Catalog`],
/// managing access to a [`Table`].
#[derive(Debug)]
pub struct IcebergTableProvider {
/// A table in the catalog.
table: Table,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -97,7 +97,7 @@ use crate::to_datafusion_error;
/// # Errors
/// An error will be returned if any unsupported feature, such as partition columns,
/// order expressions, constraints, or column defaults, is detected in the table creation command.
#[derive(Default)]
#[derive(Debug, Default)]
pub struct IcebergTableProviderFactory {}

impl IcebergTableProviderFactory {
Expand Down Expand Up @@ -241,6 +241,7 @@ mod tests {
constraints: Constraints::empty(),
column_defaults: Default::default(),
if_not_exists: Default::default(),
temporary: false,
definition: Default::default(),
unbounded: Default::default(),
}
Expand Down

0 comments on commit e1f31c5

Please sign in to comment.