We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 25ddb2f commit 89fc0f6Copy full SHA for 89fc0f6
pyiceberg/table/__init__.py
@@ -147,6 +147,7 @@
147
import pyarrow as pa
148
import ray
149
from duckdb import DuckDBPyConnection
150
+ from pyiceberg_core.datafusion import IcebergDataFusionTable
151
152
from pyiceberg.catalog import Catalog
153
@@ -1428,7 +1429,7 @@ def to_polars(self) -> pl.LazyFrame:
1428
1429
1430
return pl.scan_iceberg(self)
1431
- def __datafusion_table_provider__(self) -> Any:
1432
+ def __datafusion_table_provider__(self) -> "IcebergDataFusionTable":
1433
"""Return the DataFusion table provider PyCapsule interface.
1434
1435
To support DataFusion features such as push down filtering, this function will return a PyCapsule
0 commit comments