We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 299fc48 commit 15899b5Copy full SHA for 15899b5
pyiceberg/table/__init__.py
@@ -143,6 +143,7 @@
143
import pyarrow as pa
144
import ray
145
from duckdb import DuckDBPyConnection
146
+ from pyiceberg_core.datafusion import IcebergDataFusionTable
147
148
from pyiceberg.catalog import Catalog
149
@@ -1494,7 +1495,7 @@ def to_polars(self) -> pl.LazyFrame:
1494
1495
1496
return pl.scan_iceberg(self)
1497
- def __datafusion_table_provider__(self) -> Any:
1498
+ def __datafusion_table_provider__(self) -> "IcebergDataFusionTable":
1499
"""Return the DataFusion table provider PyCapsule interface.
1500
1501
To support DataFusion features such as push down filtering, this function will return a PyCapsule
0 commit comments