From commits-return-113258-archive-asf-public=cust-asf.ponee.io@beam.apache.org Thu Mar 11 07:55:59 2021 Return-Path: X-Original-To: archive-asf-public@cust-asf.ponee.io Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mxout1-ec2-va.apache.org (mxout1-ec2-va.apache.org [3.227.148.255]) by mx-eu-01.ponee.io (Postfix) with ESMTPS id 8EF6B18062C for ; Thu, 11 Mar 2021 08:55:59 +0100 (CET) Received: from mail.apache.org (mailroute1-lw-us.apache.org [207.244.88.153]) by mxout1-ec2-va.apache.org (ASF Mail Server at mxout1-ec2-va.apache.org) with SMTP id 3E608458CC for ; Thu, 11 Mar 2021 07:55:51 +0000 (UTC) Received: (qmail 12188 invoked by uid 500); 11 Mar 2021 07:55:20 -0000 Mailing-List: contact commits-help@beam.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@beam.apache.org Delivered-To: mailing list commits@beam.apache.org Received: (qmail 12140 invoked by uid 99); 11 Mar 2021 07:55:20 -0000 Received: from ec2-52-202-80-70.compute-1.amazonaws.com (HELO gitbox.apache.org) (52.202.80.70) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 11 Mar 2021 07:55:20 +0000 Received: by gitbox.apache.org (ASF Mail Server at gitbox.apache.org, from userid 33) id BA8FA80547; Thu, 11 Mar 2021 07:55:19 +0000 (UTC) Date: Thu, 11 Mar 2021 07:55:14 +0000 To: "commits@beam.apache.org" Subject: [beam] branch master updated: [BEAM-7372] remove usage of future package from coders and dataframe (#14163) MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 8bit Message-ID: <161544930995.22352.13882259147168073481@gitbox.apache.org> From: tvalentyn@apache.org X-Git-Host: gitbox.apache.org X-Git-Repo: beam X-Git-Refname: refs/heads/master X-Git-Reftype: branch X-Git-Oldrev: f801170eb2fe527f5d62b9c3ac9fa55534ef971a X-Git-Newrev: fe8ddfc211b661ab1dc66a3f2932d04a9428b906 X-Git-Rev: fe8ddfc211b661ab1dc66a3f2932d04a9428b906 X-Git-NotificationType: ref_changed_plus_diff X-Git-Multimail-Version: 1.5.dev Auto-Submitted: auto-generated This is an automated email from the ASF dual-hosted git repository. tvalentyn pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/beam.git The following commit(s) were added to refs/heads/master by this push: new fe8ddfc [BEAM-7372] remove usage of future package from coders and dataframe (#14163) fe8ddfc is described below commit fe8ddfc211b661ab1dc66a3f2932d04a9428b906 Author: yoshiki.obata <1285728+lazylynx@users.noreply.github.com> AuthorDate: Thu Mar 11 16:54:27 2021 +0900 [BEAM-7372] remove usage of future package from coders and dataframe (#14163) --- sdks/python/apache_beam/coders/__init__.py | 2 -- sdks/python/apache_beam/coders/avro_record.py | 2 -- sdks/python/apache_beam/coders/coder_impl.py | 3 --- sdks/python/apache_beam/coders/coders.py | 2 -- sdks/python/apache_beam/coders/coders_test.py | 2 -- sdks/python/apache_beam/coders/coders_test_common.py | 2 -- sdks/python/apache_beam/coders/fast_coders_test.py | 2 -- sdks/python/apache_beam/coders/observable.py | 2 -- sdks/python/apache_beam/coders/observable_test.py | 2 -- sdks/python/apache_beam/coders/row_coder.py | 2 -- sdks/python/apache_beam/coders/row_coder_test.py | 2 -- sdks/python/apache_beam/coders/slow_coders_test.py | 2 -- sdks/python/apache_beam/coders/slow_stream.py | 2 -- sdks/python/apache_beam/coders/standard_coders_test.py | 3 --- sdks/python/apache_beam/coders/stream_test.py | 3 --- sdks/python/apache_beam/coders/typecoders.py | 2 -- sdks/python/apache_beam/coders/typecoders_test.py | 2 -- sdks/python/apache_beam/dataframe/__init__.py | 2 -- sdks/python/apache_beam/dataframe/convert.py | 2 -- sdks/python/apache_beam/dataframe/convert_test.py | 2 -- sdks/python/apache_beam/dataframe/doctests.py | 4 ---- sdks/python/apache_beam/dataframe/doctests_test.py | 2 -- sdks/python/apache_beam/dataframe/expressions.py | 2 -- sdks/python/apache_beam/dataframe/expressions_test.py | 2 -- sdks/python/apache_beam/dataframe/frame_base.py | 2 -- sdks/python/apache_beam/dataframe/frame_base_test.py | 2 -- sdks/python/apache_beam/dataframe/frames.py | 2 -- sdks/python/apache_beam/dataframe/frames_test.py | 2 -- sdks/python/apache_beam/dataframe/io.py | 2 -- sdks/python/apache_beam/dataframe/io_test.py | 3 --- sdks/python/apache_beam/dataframe/pandas_docs_test.py | 3 --- sdks/python/apache_beam/dataframe/pandas_doctests_test.py | 2 -- sdks/python/apache_beam/dataframe/partitionings.py | 2 -- sdks/python/apache_beam/dataframe/partitionings_test.py | 2 -- sdks/python/apache_beam/dataframe/schemas.py | 2 -- sdks/python/apache_beam/dataframe/schemas_test.py | 3 --- sdks/python/apache_beam/dataframe/transforms.py | 2 -- sdks/python/apache_beam/dataframe/transforms_test.py | 3 --- 38 files changed, 85 deletions(-) diff --git a/sdks/python/apache_beam/coders/__init__.py b/sdks/python/apache_beam/coders/__init__.py index 680f1c7..8063099 100644 --- a/sdks/python/apache_beam/coders/__init__.py +++ b/sdks/python/apache_beam/coders/__init__.py @@ -14,8 +14,6 @@ # See the License for the specific language governing permissions and # limitations under the License. # -from __future__ import absolute_import - from apache_beam.coders.coders import * from apache_beam.coders.row_coder import * from apache_beam.coders.typecoders import registry diff --git a/sdks/python/apache_beam/coders/avro_record.py b/sdks/python/apache_beam/coders/avro_record.py index efbaca8..c9ed26d 100644 --- a/sdks/python/apache_beam/coders/avro_record.py +++ b/sdks/python/apache_beam/coders/avro_record.py @@ -19,8 +19,6 @@ # pytype: skip-file -from __future__ import absolute_import - __all__ = ['AvroRecord'] diff --git a/sdks/python/apache_beam/coders/coder_impl.py b/sdks/python/apache_beam/coders/coder_impl.py index 9ef22c5..f262f1f 100644 --- a/sdks/python/apache_beam/coders/coder_impl.py +++ b/sdks/python/apache_beam/coders/coder_impl.py @@ -33,9 +33,6 @@ For internal use only; no backwards-compatibility guarantees. """ # pytype: skip-file -from __future__ import absolute_import -from __future__ import division - import json from builtins import chr from builtins import object diff --git a/sdks/python/apache_beam/coders/coders.py b/sdks/python/apache_beam/coders/coders.py index 6c570b0..e5c6f61 100644 --- a/sdks/python/apache_beam/coders/coders.py +++ b/sdks/python/apache_beam/coders/coders.py @@ -21,8 +21,6 @@ Only those coders listed in __all__ are part of the public API of this module. """ # pytype: skip-file -from __future__ import absolute_import - import base64 from builtins import object from typing import TYPE_CHECKING diff --git a/sdks/python/apache_beam/coders/coders_test.py b/sdks/python/apache_beam/coders/coders_test.py index 084e0d1..02e996e 100644 --- a/sdks/python/apache_beam/coders/coders_test.py +++ b/sdks/python/apache_beam/coders/coders_test.py @@ -16,8 +16,6 @@ # # pytype: skip-file -from __future__ import absolute_import - import base64 import logging import unittest diff --git a/sdks/python/apache_beam/coders/coders_test_common.py b/sdks/python/apache_beam/coders/coders_test_common.py index 3250f6b..55fcda0 100644 --- a/sdks/python/apache_beam/coders/coders_test_common.py +++ b/sdks/python/apache_beam/coders/coders_test_common.py @@ -18,8 +18,6 @@ """Tests common to all coder implementations.""" # pytype: skip-file -from __future__ import absolute_import - import logging import math import unittest diff --git a/sdks/python/apache_beam/coders/fast_coders_test.py b/sdks/python/apache_beam/coders/fast_coders_test.py index 5a3f4e6..c7112e0 100644 --- a/sdks/python/apache_beam/coders/fast_coders_test.py +++ b/sdks/python/apache_beam/coders/fast_coders_test.py @@ -18,8 +18,6 @@ """Unit tests for compiled implementation of coder impls.""" # pytype: skip-file -from __future__ import absolute_import - import logging import unittest diff --git a/sdks/python/apache_beam/coders/observable.py b/sdks/python/apache_beam/coders/observable.py index e0edf12..94104a0 100644 --- a/sdks/python/apache_beam/coders/observable.py +++ b/sdks/python/apache_beam/coders/observable.py @@ -21,8 +21,6 @@ For internal use only; no backwards-compatibility guarantees. """ # pytype: skip-file -from __future__ import absolute_import - from builtins import object diff --git a/sdks/python/apache_beam/coders/observable_test.py b/sdks/python/apache_beam/coders/observable_test.py index 2ef0fe1..46f5186 100644 --- a/sdks/python/apache_beam/coders/observable_test.py +++ b/sdks/python/apache_beam/coders/observable_test.py @@ -18,8 +18,6 @@ """Tests for the Observable mixin class.""" # pytype: skip-file -from __future__ import absolute_import - import logging import unittest from typing import List diff --git a/sdks/python/apache_beam/coders/row_coder.py b/sdks/python/apache_beam/coders/row_coder.py index ecb2bf3..7879d82 100644 --- a/sdks/python/apache_beam/coders/row_coder.py +++ b/sdks/python/apache_beam/coders/row_coder.py @@ -17,8 +17,6 @@ # pytype: skip-file -from __future__ import absolute_import - import itertools from array import array diff --git a/sdks/python/apache_beam/coders/row_coder_test.py b/sdks/python/apache_beam/coders/row_coder_test.py index 9f087a1..210e31b 100644 --- a/sdks/python/apache_beam/coders/row_coder_test.py +++ b/sdks/python/apache_beam/coders/row_coder_test.py @@ -16,8 +16,6 @@ # # pytype: skip-file -from __future__ import absolute_import - import logging import typing import unittest diff --git a/sdks/python/apache_beam/coders/slow_coders_test.py b/sdks/python/apache_beam/coders/slow_coders_test.py index 348205f..fe1c707 100644 --- a/sdks/python/apache_beam/coders/slow_coders_test.py +++ b/sdks/python/apache_beam/coders/slow_coders_test.py @@ -18,8 +18,6 @@ """Unit tests for uncompiled implementation of coder impls.""" # pytype: skip-file -from __future__ import absolute_import - import logging import unittest diff --git a/sdks/python/apache_beam/coders/slow_stream.py b/sdks/python/apache_beam/coders/slow_stream.py index 5840e24..b485309 100644 --- a/sdks/python/apache_beam/coders/slow_stream.py +++ b/sdks/python/apache_beam/coders/slow_stream.py @@ -21,8 +21,6 @@ For internal use only; no backwards-compatibility guarantees. """ # pytype: skip-file -from __future__ import absolute_import - import struct from builtins import chr from builtins import object diff --git a/sdks/python/apache_beam/coders/standard_coders_test.py b/sdks/python/apache_beam/coders/standard_coders_test.py index 87320c8..385790d 100644 --- a/sdks/python/apache_beam/coders/standard_coders_test.py +++ b/sdks/python/apache_beam/coders/standard_coders_test.py @@ -19,9 +19,6 @@ """ # pytype: skip-file -from __future__ import absolute_import -from __future__ import print_function - import json import logging import math diff --git a/sdks/python/apache_beam/coders/stream_test.py b/sdks/python/apache_beam/coders/stream_test.py index b84d338..900d037 100644 --- a/sdks/python/apache_beam/coders/stream_test.py +++ b/sdks/python/apache_beam/coders/stream_test.py @@ -18,9 +18,6 @@ """Tests for the stream implementations.""" # pytype: skip-file -from __future__ import absolute_import -from __future__ import division - import logging import math import unittest diff --git a/sdks/python/apache_beam/coders/typecoders.py b/sdks/python/apache_beam/coders/typecoders.py index ba57c84..844110c 100644 --- a/sdks/python/apache_beam/coders/typecoders.py +++ b/sdks/python/apache_beam/coders/typecoders.py @@ -66,8 +66,6 @@ See apache_beam.typehints.decorators module for more details. # pytype: skip-file -from __future__ import absolute_import - from builtins import object from typing import Any from typing import Dict diff --git a/sdks/python/apache_beam/coders/typecoders_test.py b/sdks/python/apache_beam/coders/typecoders_test.py index dec478f..dd2156a 100644 --- a/sdks/python/apache_beam/coders/typecoders_test.py +++ b/sdks/python/apache_beam/coders/typecoders_test.py @@ -18,8 +18,6 @@ """Unit tests for the typecoders module.""" # pytype: skip-file -from __future__ import absolute_import - import unittest from builtins import object diff --git a/sdks/python/apache_beam/dataframe/__init__.py b/sdks/python/apache_beam/dataframe/__init__.py index 9071a88..e0aa42b 100644 --- a/sdks/python/apache_beam/dataframe/__init__.py +++ b/sdks/python/apache_beam/dataframe/__init__.py @@ -14,6 +14,4 @@ # See the License for the specific language governing permissions and # limitations under the License. -from __future__ import absolute_import - from apache_beam.dataframe.expressions import allow_non_parallel_operations diff --git a/sdks/python/apache_beam/dataframe/convert.py b/sdks/python/apache_beam/dataframe/convert.py index aad15ac1..2b207dd 100644 --- a/sdks/python/apache_beam/dataframe/convert.py +++ b/sdks/python/apache_beam/dataframe/convert.py @@ -14,8 +14,6 @@ # See the License for the specific language governing permissions and # limitations under the License. -from __future__ import absolute_import - import inspect import weakref from typing import TYPE_CHECKING diff --git a/sdks/python/apache_beam/dataframe/convert_test.py b/sdks/python/apache_beam/dataframe/convert_test.py index 638accf..06a1001 100644 --- a/sdks/python/apache_beam/dataframe/convert_test.py +++ b/sdks/python/apache_beam/dataframe/convert_test.py @@ -14,8 +14,6 @@ # See the License for the specific language governing permissions and # limitations under the License. -from __future__ import absolute_import - import unittest import pandas as pd diff --git a/sdks/python/apache_beam/dataframe/doctests.py b/sdks/python/apache_beam/dataframe/doctests.py index 8cb2d8f..ca547da 100644 --- a/sdks/python/apache_beam/dataframe/doctests.py +++ b/sdks/python/apache_beam/dataframe/doctests.py @@ -37,10 +37,6 @@ The (novel) sequence of events when running a doctest is as follows. values. """ -from __future__ import absolute_import -from __future__ import division -from __future__ import print_function - import collections import contextlib import doctest diff --git a/sdks/python/apache_beam/dataframe/doctests_test.py b/sdks/python/apache_beam/dataframe/doctests_test.py index d3030fb..1adff65 100644 --- a/sdks/python/apache_beam/dataframe/doctests_test.py +++ b/sdks/python/apache_beam/dataframe/doctests_test.py @@ -14,8 +14,6 @@ # See the License for the specific language governing permissions and # limitations under the License. -from __future__ import absolute_import - import doctest import os import tempfile diff --git a/sdks/python/apache_beam/dataframe/expressions.py b/sdks/python/apache_beam/dataframe/expressions.py index 0c04944..1c3aed7 100644 --- a/sdks/python/apache_beam/dataframe/expressions.py +++ b/sdks/python/apache_beam/dataframe/expressions.py @@ -14,8 +14,6 @@ # See the License for the specific language governing permissions and # limitations under the License. -from __future__ import absolute_import - import contextlib import random import threading diff --git a/sdks/python/apache_beam/dataframe/expressions_test.py b/sdks/python/apache_beam/dataframe/expressions_test.py index fbbf025..7033783 100644 --- a/sdks/python/apache_beam/dataframe/expressions_test.py +++ b/sdks/python/apache_beam/dataframe/expressions_test.py @@ -14,8 +14,6 @@ # See the License for the specific language governing permissions and # limitations under the License. -from __future__ import absolute_import - import unittest from apache_beam.dataframe import expressions diff --git a/sdks/python/apache_beam/dataframe/frame_base.py b/sdks/python/apache_beam/dataframe/frame_base.py index 7674fb2..433856e 100644 --- a/sdks/python/apache_beam/dataframe/frame_base.py +++ b/sdks/python/apache_beam/dataframe/frame_base.py @@ -14,8 +14,6 @@ # See the License for the specific language governing permissions and # limitations under the License. -from __future__ import absolute_import - import functools from inspect import getfullargspec from inspect import unwrap diff --git a/sdks/python/apache_beam/dataframe/frame_base_test.py b/sdks/python/apache_beam/dataframe/frame_base_test.py index 557fedb..82d5b65 100644 --- a/sdks/python/apache_beam/dataframe/frame_base_test.py +++ b/sdks/python/apache_beam/dataframe/frame_base_test.py @@ -14,8 +14,6 @@ # See the License for the specific language governing permissions and # limitations under the License. -from __future__ import absolute_import - import unittest import pandas as pd diff --git a/sdks/python/apache_beam/dataframe/frames.py b/sdks/python/apache_beam/dataframe/frames.py index 994048e..148d1a2 100644 --- a/sdks/python/apache_beam/dataframe/frames.py +++ b/sdks/python/apache_beam/dataframe/frames.py @@ -14,8 +14,6 @@ # See the License for the specific language governing permissions and # limitations under the License. -from __future__ import absolute_import - import collections import inspect import math diff --git a/sdks/python/apache_beam/dataframe/frames_test.py b/sdks/python/apache_beam/dataframe/frames_test.py index 7b888d1..98ad565 100644 --- a/sdks/python/apache_beam/dataframe/frames_test.py +++ b/sdks/python/apache_beam/dataframe/frames_test.py @@ -14,8 +14,6 @@ # See the License for the specific language governing permissions and # limitations under the License. -from __future__ import absolute_import - import sys import unittest diff --git a/sdks/python/apache_beam/dataframe/io.py b/sdks/python/apache_beam/dataframe/io.py index b51e85e..162e023 100644 --- a/sdks/python/apache_beam/dataframe/io.py +++ b/sdks/python/apache_beam/dataframe/io.py @@ -14,8 +14,6 @@ # See the License for the specific language governing permissions and # limitations under the License. -from __future__ import absolute_import - import itertools import re from io import BytesIO diff --git a/sdks/python/apache_beam/dataframe/io_test.py b/sdks/python/apache_beam/dataframe/io_test.py index 6ae16f2..32a0d9c 100644 --- a/sdks/python/apache_beam/dataframe/io_test.py +++ b/sdks/python/apache_beam/dataframe/io_test.py @@ -14,9 +14,6 @@ # See the License for the specific language governing permissions and # limitations under the License. -from __future__ import absolute_import -from __future__ import print_function - import glob import importlib import math diff --git a/sdks/python/apache_beam/dataframe/pandas_docs_test.py b/sdks/python/apache_beam/dataframe/pandas_docs_test.py index 449656e..d52773c 100644 --- a/sdks/python/apache_beam/dataframe/pandas_docs_test.py +++ b/sdks/python/apache_beam/dataframe/pandas_docs_test.py @@ -20,9 +20,6 @@ dataframe implementation. Run as python -m apache_beam.dataframe.pandas_docs_test [getting_started ...] """ -from __future__ import absolute_import -from __future__ import print_function - import argparse import contextlib import io diff --git a/sdks/python/apache_beam/dataframe/pandas_doctests_test.py b/sdks/python/apache_beam/dataframe/pandas_doctests_test.py index 1144d42..e48b38a 100644 --- a/sdks/python/apache_beam/dataframe/pandas_doctests_test.py +++ b/sdks/python/apache_beam/dataframe/pandas_doctests_test.py @@ -14,8 +14,6 @@ # See the License for the specific language governing permissions and # limitations under the License. -from __future__ import absolute_import - import sys import unittest diff --git a/sdks/python/apache_beam/dataframe/partitionings.py b/sdks/python/apache_beam/dataframe/partitionings.py index a67bbac..aa3d1c1 100644 --- a/sdks/python/apache_beam/dataframe/partitionings.py +++ b/sdks/python/apache_beam/dataframe/partitionings.py @@ -14,8 +14,6 @@ # See the License for the specific language governing permissions and # limitations under the License. -from __future__ import absolute_import - import random from typing import Any from typing import Iterable diff --git a/sdks/python/apache_beam/dataframe/partitionings_test.py b/sdks/python/apache_beam/dataframe/partitionings_test.py index 70a5e99..85f6112 100644 --- a/sdks/python/apache_beam/dataframe/partitionings_test.py +++ b/sdks/python/apache_beam/dataframe/partitionings_test.py @@ -14,8 +14,6 @@ # See the License for the specific language governing permissions and # limitations under the License. -from __future__ import absolute_import - import unittest import pandas as pd diff --git a/sdks/python/apache_beam/dataframe/schemas.py b/sdks/python/apache_beam/dataframe/schemas.py index 32acbd9..cc30cec 100644 --- a/sdks/python/apache_beam/dataframe/schemas.py +++ b/sdks/python/apache_beam/dataframe/schemas.py @@ -57,8 +57,6 @@ types may be given special consideration. #TODO: Mapping for date/time types #https://pandas.pydata.org/docs/user_guide/timeseries.html#overview -from __future__ import absolute_import - from typing import Any from typing import NamedTuple from typing import Optional diff --git a/sdks/python/apache_beam/dataframe/schemas_test.py b/sdks/python/apache_beam/dataframe/schemas_test.py index a52ef0e..6011475 100644 --- a/sdks/python/apache_beam/dataframe/schemas_test.py +++ b/sdks/python/apache_beam/dataframe/schemas_test.py @@ -19,12 +19,9 @@ # pytype: skip-file -from __future__ import absolute_import - import typing import unittest -import future.tests.base # pylint: disable=unused-import import numpy as np # patches unittest.testcase to be python3 compatible import pandas as pd diff --git a/sdks/python/apache_beam/dataframe/transforms.py b/sdks/python/apache_beam/dataframe/transforms.py index b403f32..d46a340 100644 --- a/sdks/python/apache_beam/dataframe/transforms.py +++ b/sdks/python/apache_beam/dataframe/transforms.py @@ -14,8 +14,6 @@ # See the License for the specific language governing permissions and # limitations under the License. -from __future__ import absolute_import - import collections from typing import TYPE_CHECKING from typing import Any diff --git a/sdks/python/apache_beam/dataframe/transforms_test.py b/sdks/python/apache_beam/dataframe/transforms_test.py index 20815c2..9b846a8 100644 --- a/sdks/python/apache_beam/dataframe/transforms_test.py +++ b/sdks/python/apache_beam/dataframe/transforms_test.py @@ -14,9 +14,6 @@ # See the License for the specific language governing permissions and # limitations under the License. -from __future__ import absolute_import -from __future__ import division - import typing import unittest