|
26 | 26 | npt, |
27 | 27 | ) |
28 | 28 | from pandas.compat import ( |
29 | | - pa_version_under6p0, |
30 | 29 | pa_version_under7p0, |
31 | 30 | pa_version_under8p0, |
32 | 31 | pa_version_under9p0, |
|
54 | 53 | validate_indices, |
55 | 54 | ) |
56 | 55 |
|
57 | | -if not pa_version_under6p0: |
| 56 | +if not pa_version_under7p0: |
58 | 57 | import pyarrow as pa |
59 | 58 | import pyarrow.compute as pc |
60 | 59 |
|
@@ -199,8 +198,8 @@ class ArrowExtensionArray(OpsMixin, ExtensionArray): |
199 | 198 | _dtype: ArrowDtype |
200 | 199 |
|
201 | 200 | def __init__(self, values: pa.Array | pa.ChunkedArray) -> None: |
202 | | - if pa_version_under6p0: |
203 | | - msg = "pyarrow>=6.0.0 is required for PyArrow backed ArrowExtensionArray." |
| 201 | + if pa_version_under7p0: |
| 202 | + msg = "pyarrow>=7.0.0 is required for PyArrow backed ArrowExtensionArray." |
204 | 203 | raise ImportError(msg) |
205 | 204 | if isinstance(values, pa.Array): |
206 | 205 | self._data = pa.chunked_array([values]) |
@@ -529,11 +528,6 @@ def _argmin_max(self, skipna: bool, method: str) -> int: |
529 | 528 | # let ExtensionArray.arg{max|min} raise |
530 | 529 | return getattr(super(), f"arg{method}")(skipna=skipna) |
531 | 530 |
|
532 | | - if pa_version_under6p0: |
533 | | - raise NotImplementedError( |
534 | | - f"arg{method} only implemented for pyarrow version >= 6.0" |
535 | | - ) |
536 | | - |
537 | 531 | data = self._data |
538 | 532 | if pa.types.is_duration(data.type): |
539 | 533 | data = data.cast(pa.int64()) |
@@ -567,11 +561,7 @@ def dropna(self: ArrowExtensionArrayT) -> ArrowExtensionArrayT: |
567 | 561 | ------- |
568 | 562 | ArrowExtensionArray |
569 | 563 | """ |
570 | | - if pa_version_under6p0: |
571 | | - fallback_performancewarning(version="6") |
572 | | - return super().dropna() |
573 | | - else: |
574 | | - return type(self)(pc.drop_null(self._data)) |
| 564 | + return type(self)(pc.drop_null(self._data)) |
575 | 565 |
|
576 | 566 | @doc(ExtensionArray.fillna) |
577 | 567 | def fillna( |
@@ -1293,9 +1283,6 @@ def _mode(self: ArrowExtensionArrayT, dropna: bool = True) -> ArrowExtensionArra |
1293 | 1283 | same type as self |
1294 | 1284 | Sorted, if possible. |
1295 | 1285 | """ |
1296 | | - if pa_version_under6p0: |
1297 | | - raise NotImplementedError("mode only supported for pyarrow version >= 6.0") |
1298 | | - |
1299 | 1286 | pa_type = self._data.type |
1300 | 1287 | if pa.types.is_temporal(pa_type): |
1301 | 1288 | nbits = pa_type.bit_width |
|
0 commit comments