Skip to content
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
22 commits
Select commit Hold shift + click to select a range
a43741b
init
NoahKusaba Jul 21, 2026
63e9b61
merge tests
NoahKusaba Jul 21, 2026
5a8e388
Merge branch 'main' into feature/datafusion-snapshot-id
NoahKusaba Jul 21, 2026
60b5c1a
cleanup
NoahKusaba Jul 21, 2026
4fe1ebb
make tests assert batch
NoahKusaba Jul 21, 2026
345b0b3
Merge branch 'main' into feature/datafusion-snapshot-id
NoahKusaba Jul 22, 2026
b97ce72
fix read-insert-read snapshot
NoahKusaba Jul 23, 2026
f49bf31
Merge branch 'main' into feature/datafusion-snapshot-id
NoahKusaba Jul 23, 2026
edb11db
Merge branch 'main' into feature/datafusion-snapshot-id
NoahKusaba Jul 24, 2026
3e42a9e
fix schema version error
NoahKusaba Jul 24, 2026
a9215c7
fix test
NoahKusaba Jul 24, 2026
a29b460
Merge branch 'main' into feature/datafusion-snapshot-id
NoahKusaba Jul 24, 2026
cb218e5
make snapshot_arrow_schema public
NoahKusaba Jul 25, 2026
9d92b11
reload table in with_snapshot_id, get rid of Table Parameter
NoahKusaba Jul 26, 2026
bd0c036
Merge branch 'main' into feature/datafusion-snapshot-id
NoahKusaba Jul 26, 2026
fe72134
simplify tests
NoahKusaba Jul 26, 2026
bfd3aca
Merge branch 'main' into feature/datafusion-snapshot-id
NoahKusaba Jul 27, 2026
43e123d
Merge branch 'main' into feature/datafusion-snapshot-id
NoahKusaba Aug 1, 2026
4e25485
Merge branch 'main' into feature/datafusion-snapshot-id
NoahKusaba Aug 4, 2026
1c71c7d
Merge branch 'main' into feature/datafusion-snapshot-id
NoahKusaba Aug 5, 2026
1258792
Merge branch 'main' into feature/datafusion-snapshot-id
NoahKusaba Aug 6, 2026
97e24f5
Merge branch 'main' into feature/datafusion-snapshot-id
NoahKusaba Aug 7, 2026
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
8 changes: 8 additions & 0 deletions crates/integrations/datafusion/public-api.txt
Original file line number Diff line number Diff line change
Expand Up @@ -70,6 +70,9 @@ pub fn iceberg_datafusion::IcebergStaticTableProvider::schema(&self) -> arrow_sc
pub fn iceberg_datafusion::IcebergStaticTableProvider::supports_filters_pushdown(&self, filters: &[&datafusion_expr::expr::Expr]) -> datafusion_common::error::Result<alloc::vec::Vec<datafusion_expr::table_source::TableProviderFilterPushDown>>
pub fn iceberg_datafusion::IcebergStaticTableProvider::table_type(&self) -> datafusion_expr::table_source::TableType
pub struct iceberg_datafusion::table::IcebergTableProvider
impl iceberg_datafusion::IcebergTableProvider
pub fn iceberg_datafusion::IcebergTableProvider::snapshot_id(&self) -> core::option::Option<i64>
pub async fn iceberg_datafusion::IcebergTableProvider::with_snapshot_id(self, snapshot_id: core::option::Option<i64>) -> iceberg::error::Result<Self>
impl core::clone::Clone for iceberg_datafusion::IcebergTableProvider
pub fn iceberg_datafusion::IcebergTableProvider::clone(&self) -> iceberg_datafusion::IcebergTableProvider
impl core::fmt::Debug for iceberg_datafusion::IcebergTableProvider
Expand All @@ -80,6 +83,7 @@ pub fn iceberg_datafusion::IcebergTableProvider::scan<'life0, 'life1, 'life2, 'l
pub fn iceberg_datafusion::IcebergTableProvider::schema(&self) -> arrow_schema::schema::SchemaRef
pub fn iceberg_datafusion::IcebergTableProvider::supports_filters_pushdown(&self, filters: &[&datafusion_expr::expr::Expr]) -> datafusion_common::error::Result<alloc::vec::Vec<datafusion_expr::table_source::TableProviderFilterPushDown>>
pub fn iceberg_datafusion::IcebergTableProvider::table_type(&self) -> datafusion_expr::table_source::TableType
pub fn iceberg_datafusion::table::snapshot_arrow_schema(table: &iceberg::table::Table, snapshot_id: core::option::Option<i64>) -> iceberg::error::Result<arrow_schema::schema::SchemaRef>
pub mod iceberg_datafusion::table_provider_factory
pub struct iceberg_datafusion::table_provider_factory::IcebergTableProviderFactory
impl iceberg_datafusion::table_provider_factory::IcebergTableProviderFactory
Expand Down Expand Up @@ -114,6 +118,9 @@ pub fn iceberg_datafusion::IcebergStaticTableProvider::schema(&self) -> arrow_sc
pub fn iceberg_datafusion::IcebergStaticTableProvider::supports_filters_pushdown(&self, filters: &[&datafusion_expr::expr::Expr]) -> datafusion_common::error::Result<alloc::vec::Vec<datafusion_expr::table_source::TableProviderFilterPushDown>>
pub fn iceberg_datafusion::IcebergStaticTableProvider::table_type(&self) -> datafusion_expr::table_source::TableType
pub struct iceberg_datafusion::IcebergTableProvider
impl iceberg_datafusion::IcebergTableProvider
pub fn iceberg_datafusion::IcebergTableProvider::snapshot_id(&self) -> core::option::Option<i64>
pub async fn iceberg_datafusion::IcebergTableProvider::with_snapshot_id(self, snapshot_id: core::option::Option<i64>) -> iceberg::error::Result<Self>
impl core::clone::Clone for iceberg_datafusion::IcebergTableProvider
pub fn iceberg_datafusion::IcebergTableProvider::clone(&self) -> iceberg_datafusion::IcebergTableProvider
impl core::fmt::Debug for iceberg_datafusion::IcebergTableProvider
Expand All @@ -135,4 +142,5 @@ pub fn iceberg_datafusion::table_provider_factory::IcebergTableProviderFactory::
impl datafusion_catalog::table::TableProviderFactory for iceberg_datafusion::table_provider_factory::IcebergTableProviderFactory
pub fn iceberg_datafusion::table_provider_factory::IcebergTableProviderFactory::create<'life0, 'life1, 'life2, 'async_trait>(&'life0 self, _state: &'life1 dyn datafusion_session::session::Session, cmd: &'life2 datafusion_expr::logical_plan::ddl::CreateExternalTable) -> core::pin::Pin<alloc::boxed::Box<(dyn core::future::future::Future<Output = datafusion_common::error::Result<alloc::sync::Arc<dyn datafusion_catalog::table::TableProvider>>> + core::marker::Send + 'async_trait)>> where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait
pub fn iceberg_datafusion::from_datafusion_error(error: datafusion_common::error::DataFusionError) -> iceberg::error::Error
pub fn iceberg_datafusion::snapshot_arrow_schema(table: &iceberg::table::Table, snapshot_id: core::option::Option<i64>) -> iceberg::error::Result<arrow_schema::schema::SchemaRef>
pub fn iceberg_datafusion::to_datafusion_error(error: iceberg::error::Error) -> datafusion_common::error::DataFusionError
Loading
Loading