Skip to content

Commit 007b9da

Browse files
committed
ensure large type
1 parent ad53ec2 commit 007b9da

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

pyiceberg/io/pyarrow.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1715,8 +1715,8 @@ def _cast_if_needed(self, field: NestedField, values: pa.Array) -> pa.Array:
17151715
target_schema = schema_to_pyarrow(
17161716
promote(file_field.field_type, field.field_type), include_field_ids=self._include_field_ids
17171717
)
1718-
if self._use_large_types is False:
1719-
target_schema = _pyarrow_schema_ensure_small_types(target_schema)
1718+
if self._use_large_types is True:
1719+
target_schema = _pyarrow_schema_ensure_large_types(target_schema)
17201720
return values.cast(target_schema)
17211721
elif (target_type := schema_to_pyarrow(field.field_type, include_field_ids=self._include_field_ids)) != values.type:
17221722
if field.field_type == TimestampType():

0 commit comments

Comments
 (0)