File tree Expand file tree Collapse file tree 3 files changed +19
-2
lines changed
crates/integrations/datafusion/src Expand file tree Collapse file tree 3 files changed +19
-2
lines changed Original file line number Diff line number Diff line change @@ -21,7 +21,7 @@ pub use catalog::*;
2121mod error;
2222pub use error:: * ;
2323
24- mod physical_plan;
24+ pub mod physical_plan;
2525mod schema;
2626pub mod table;
2727pub use table:: table_provider_factory:: IcebergTableProviderFactory ;
Original file line number Diff line number Diff line change 1818pub ( crate ) mod expr_to_predicate;
1919pub ( crate ) mod metadata_scan;
2020pub ( crate ) mod scan;
21+ pub use scan:: IcebergTableScan ;
Original file line number Diff line number Diff line change @@ -39,7 +39,7 @@ use crate::to_datafusion_error;
3939/// Manages the scanning process of an Iceberg [`Table`], encapsulating the
4040/// necessary details and computed properties required for execution planning.
4141#[ derive( Debug ) ]
42- pub ( crate ) struct IcebergTableScan {
42+ pub struct IcebergTableScan {
4343 /// A table in the catalog.
4444 table : Table ,
4545 /// Snapshot of the table to scan.
@@ -79,6 +79,22 @@ impl IcebergTableScan {
7979 }
8080 }
8181
82+ pub fn table ( & self ) -> & Table {
83+ & self . table
84+ }
85+
86+ pub fn snapshot_id ( & self ) -> Option < i64 > {
87+ self . snapshot_id
88+ }
89+
90+ pub fn projection ( & self ) -> Option < & Vec < String > > {
91+ self . projection . as_ref ( )
92+ }
93+
94+ pub fn predicates ( & self ) -> Option < & Predicate > {
95+ self . predicates . as_ref ( )
96+ }
97+
8298 /// Computes [`PlanProperties`] used in query optimization.
8399 fn compute_properties ( schema : ArrowSchemaRef ) -> PlanProperties {
84100 // TODO:
You can’t perform that action at this time.
0 commit comments