You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iceberg.apache.org by bl...@apache.org on 2022/12/06 20:32:43 UTC

[iceberg] branch master updated: Python: Fix PyArrow import (#6362)

This is an automated email from the ASF dual-hosted git repository.

blue pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iceberg.git


The following commit(s) were added to refs/heads/master by this push:
     new 75bf001eef Python: Fix PyArrow import (#6362)
75bf001eef is described below

commit 75bf001eef3898b3e6a36cb4221e1413f31d48cf
Author: Fokko Driesprong <fo...@apache.org>
AuthorDate: Tue Dec 6 21:32:34 2022 +0100

    Python: Fix PyArrow import (#6362)
---
 python/pyiceberg/table/__init__.py | 3 +--
 1 file changed, 1 insertion(+), 2 deletions(-)

diff --git a/python/pyiceberg/table/__init__.py b/python/pyiceberg/table/__init__.py
index 3412e8ee2f..0bb76a4f4b 100644
--- a/python/pyiceberg/table/__init__.py
+++ b/python/pyiceberg/table/__init__.py
@@ -42,7 +42,6 @@ from pyiceberg.expressions import (
 )
 from pyiceberg.expressions.visitors import bind, inclusive_projection
 from pyiceberg.io import FileIO
-from pyiceberg.io.pyarrow import expression_to_pyarrow, schema_to_pyarrow
 from pyiceberg.manifest import DataFile, ManifestFile, files
 from pyiceberg.partitioning import PartitionSpec
 from pyiceberg.schema import Schema
@@ -335,7 +334,7 @@ class DataScan(TableScan["DataScan"]):
             yield from (FileScanTask(file) for file in matching_partition_files)
 
     def to_arrow(self):
-        from pyiceberg.io.pyarrow import PyArrowFileIO
+        from pyiceberg.io.pyarrow import PyArrowFileIO, expression_to_pyarrow, schema_to_pyarrow
 
         warnings.warn(
             "Projection is currently done by name instead of Field ID, this can lead to incorrect results in some cases."