beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rober...@apache.org
Subject [4/4] beam git commit: Closes #3785
Date Fri, 01 Sep 2017 22:09:53 GMT
Closes #3785


Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/3aa2bef8
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/3aa2bef8
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/3aa2bef8

Branch: refs/heads/master
Commit: 3aa2bef87c93d2844dd7c8dbaf45db75ec607792
Parents: 7d53878 0f91f08
Author: Robert Bradshaw <robertwb@gmail.com>
Authored: Fri Sep 1 15:09:12 2017 -0700
Committer: Robert Bradshaw <robertwb@gmail.com>
Committed: Fri Sep 1 15:09:12 2017 -0700

----------------------------------------------------------------------
 sdks/python/apache_beam/coders/coder_impl.py    |  4 ++--
 sdks/python/apache_beam/coders/coders.py        |  3 ++-
 sdks/python/apache_beam/coders/coders_test.py   |  2 +-
 .../apache_beam/coders/coders_test_common.py    |  9 ++++----
 .../apache_beam/coders/observable_test.py       |  1 -
 .../coders/proto2_coder_test_messages_pb2.py    |  6 ++---
 .../apache_beam/coders/standard_coders_test.py  |  6 ++---
 sdks/python/apache_beam/coders/stream_test.py   |  1 -
 sdks/python/apache_beam/coders/typecoders.py    |  1 -
 .../examples/complete/estimate_pi.py            |  5 ++--
 .../examples/complete/estimate_pi_test.py       |  2 +-
 .../complete/juliaset/juliaset/juliaset_test.py |  1 -
 .../examples/complete/juliaset/juliaset_main.py |  2 --
 .../examples/complete/juliaset/setup.py         |  2 +-
 .../apache_beam/examples/complete/tfidf.py      |  2 +-
 .../apache_beam/examples/complete/tfidf_test.py |  1 -
 .../examples/complete/top_wikipedia_sessions.py |  5 ++--
 .../complete/top_wikipedia_sessions_test.py     |  1 -
 .../examples/cookbook/bigquery_side_input.py    |  5 ++--
 .../cookbook/bigquery_tornadoes_it_test.py      |  2 +-
 .../examples/cookbook/custom_ptransform.py      |  2 +-
 .../examples/cookbook/datastore_wordcount.py    |  3 ++-
 .../examples/cookbook/group_with_coder.py       |  4 ++--
 .../examples/cookbook/group_with_coder_test.py  |  1 -
 .../apache_beam/examples/snippets/snippets.py   | 11 ++++-----
 .../examples/snippets/snippets_test.py          |  6 ++---
 .../apache_beam/examples/streaming_wordcount.py |  3 +--
 .../apache_beam/examples/windowed_wordcount.py  |  1 -
 .../apache_beam/examples/wordcount_it_test.py   |  2 +-
 sdks/python/apache_beam/internal/gcp/auth.py    |  1 -
 .../apache_beam/internal/gcp/json_value.py      |  1 -
 .../apache_beam/internal/gcp/json_value_test.py |  3 +--
 sdks/python/apache_beam/internal/util.py        |  2 +-
 sdks/python/apache_beam/io/avroio.py            |  4 ++--
 sdks/python/apache_beam/io/avroio_test.py       | 21 ++++++++---------
 .../python/apache_beam/io/concat_source_test.py |  1 -
 sdks/python/apache_beam/io/filebasedsink.py     |  4 ++--
 .../python/apache_beam/io/filebasedsink_test.py |  3 +--
 sdks/python/apache_beam/io/filebasedsource.py   | 16 ++++++-------
 .../apache_beam/io/filebasedsource_test.py      |  8 +++----
 sdks/python/apache_beam/io/filesystem.py        |  4 ++--
 sdks/python/apache_beam/io/filesystem_test.py   |  5 ++--
 sdks/python/apache_beam/io/filesystems.py       |  1 -
 sdks/python/apache_beam/io/filesystems_test.py  |  4 ++--
 sdks/python/apache_beam/io/gcp/bigquery.py      |  4 ++--
 sdks/python/apache_beam/io/gcp/bigquery_test.py |  4 ++--
 .../gcp/datastore/v1/adaptive_throttler_test.py |  1 +
 .../io/gcp/datastore/v1/datastoreio.py          | 23 ++++++++++---------
 .../io/gcp/datastore/v1/datastoreio_test.py     |  6 +++--
 .../apache_beam/io/gcp/datastore/v1/helper.py   |  9 +++++---
 .../io/gcp/datastore/v1/helper_test.py          |  5 ++--
 .../apache_beam/io/gcp/gcsfilesystem_test.py    |  1 +
 sdks/python/apache_beam/io/gcp/gcsio.py         |  1 +
 .../clients/bigquery/bigquery_v2_messages.py    |  3 ---
 .../clients/storage/storage_v1_messages.py      |  3 ---
 sdks/python/apache_beam/io/gcp/pubsub.py        |  5 ++--
 sdks/python/apache_beam/io/gcp/pubsub_test.py   |  5 ++--
 .../io/gcp/tests/bigquery_matcher_test.py       |  3 ++-
 .../apache_beam/io/gcp/tests/utils_test.py      |  4 +++-
 sdks/python/apache_beam/io/iobase.py            |  7 +++---
 .../apache_beam/io/localfilesystem_test.py      |  4 ++--
 sdks/python/apache_beam/io/source_test_utils.py |  4 ++--
 .../apache_beam/io/source_test_utils_test.py    |  2 +-
 sdks/python/apache_beam/io/sources_test.py      |  1 -
 sdks/python/apache_beam/io/textio.py            |  5 ++--
 sdks/python/apache_beam/io/textio_test.py       | 18 ++++++---------
 sdks/python/apache_beam/io/tfrecordio.py        |  5 ++--
 sdks/python/apache_beam/io/tfrecordio_test.py   |  8 +++----
 sdks/python/apache_beam/metrics/cells_test.py   |  2 +-
 sdks/python/apache_beam/metrics/execution.py    |  5 ++--
 .../apache_beam/metrics/execution_test.py       |  4 ++--
 sdks/python/apache_beam/metrics/metric.py       |  3 ++-
 sdks/python/apache_beam/metrics/metric_test.py  |  2 +-
 .../apache_beam/options/pipeline_options.py     |  5 ++--
 .../options/pipeline_options_test.py            |  7 +++---
 .../options/pipeline_options_validator_test.py  |  3 ++-
 .../apache_beam/options/value_provider.py       |  1 -
 sdks/python/apache_beam/pipeline.py             | 15 ++++++------
 sdks/python/apache_beam/pipeline_test.py        | 10 ++++----
 sdks/python/apache_beam/pvalue.py               |  1 -
 sdks/python/apache_beam/runners/common.py       |  2 +-
 sdks/python/apache_beam/runners/common_test.py  |  2 +-
 .../runners/dataflow/dataflow_metrics.py        |  2 +-
 .../runners/dataflow/dataflow_runner.py         | 13 +++++------
 .../runners/dataflow/dataflow_runner_test.py    | 12 +++++-----
 .../runners/dataflow/internal/apiclient.py      | 11 ++++-----
 .../runners/dataflow/internal/apiclient_test.py |  1 -
 .../clients/dataflow/dataflow_v1b3_messages.py  |  2 --
 .../clients/dataflow/message_matchers.py        |  1 -
 .../clients/dataflow/message_matchers_test.py   |  3 ++-
 .../runners/dataflow/internal/dependency.py     |  4 ++--
 .../dataflow/internal/dependency_test.py        |  5 ++--
 .../runners/dataflow/native_io/iobase_test.py   | 22 ++++++++----------
 .../dataflow/native_io/streaming_create.py      |  2 +-
 .../runners/dataflow/template_runner_test.py    |  2 +-
 .../runners/dataflow/test_dataflow_runner.py    |  4 ++--
 .../consumer_tracking_pipeline_visitor_test.py  |  2 +-
 .../runners/direct/direct_metrics.py            |  2 +-
 .../runners/direct/direct_metrics_test.py       |  8 +++----
 .../apache_beam/runners/direct/direct_runner.py |  9 ++++----
 .../runners/direct/evaluation_context.py        |  6 ++---
 .../runners/direct/helper_transforms.py         |  2 +-
 .../runners/direct/transform_evaluator.py       | 24 ++++++++++----------
 .../python_rpc_direct_runner.py                 |  1 -
 .../experimental/python_rpc_direct/server.py    |  6 ++---
 .../apache_beam/runners/pipeline_context.py     |  2 +-
 .../runners/portability/fn_api_runner.py        |  7 +++---
 .../portability/maptask_executor_runner.py      |  7 +++---
 .../portability/maptask_executor_runner_test.py |  6 ++---
 sdks/python/apache_beam/runners/runner.py       |  1 -
 sdks/python/apache_beam/runners/runner_test.py  |  2 +-
 .../runners/worker/bundle_processor.py          |  4 ++--
 .../apache_beam/runners/worker/data_plane.py    |  3 ++-
 .../runners/worker/data_plane_test.py           |  2 +-
 .../apache_beam/runners/worker/log_handler.py   |  3 ++-
 .../runners/worker/log_handler_test.py          |  2 +-
 .../apache_beam/runners/worker/opcounters.py    |  1 +
 .../runners/worker/opcounters_test.py           |  1 -
 .../apache_beam/runners/worker/operations.py    |  4 ++--
 .../runners/worker/sdk_worker_test.py           |  2 +-
 .../apache_beam/testing/pipeline_verifiers.py   |  1 -
 .../testing/pipeline_verifiers_test.py          |  5 ++--
 .../python/apache_beam/testing/test_pipeline.py |  6 ++---
 .../apache_beam/testing/test_pipeline_test.py   |  4 ++--
 sdks/python/apache_beam/testing/test_stream.py  |  1 -
 .../apache_beam/testing/test_stream_test.py     |  3 ++-
 sdks/python/apache_beam/testing/test_utils.py   |  5 ++--
 .../apache_beam/testing/test_utils_test.py      |  1 +
 sdks/python/apache_beam/testing/util.py         |  3 +--
 sdks/python/apache_beam/testing/util_test.py    |  4 +++-
 sdks/python/apache_beam/transforms/combiners.py |  3 +--
 .../apache_beam/transforms/combiners_test.py    |  5 ++--
 sdks/python/apache_beam/transforms/core.py      | 15 ++++++------
 .../apache_beam/transforms/create_test.py       |  6 ++---
 sdks/python/apache_beam/transforms/display.py   |  4 ++--
 .../apache_beam/transforms/display_test.py      |  6 ++---
 .../python/apache_beam/transforms/ptransform.py |  5 ++--
 .../apache_beam/transforms/ptransform_test.py   | 15 ++++++------
 .../apache_beam/transforms/sideinputs_test.py   |  3 ++-
 sdks/python/apache_beam/transforms/timeutil.py  |  1 -
 sdks/python/apache_beam/transforms/trigger.py   |  6 ++---
 .../apache_beam/transforms/trigger_test.py      |  9 ++++----
 sdks/python/apache_beam/transforms/util.py      |  1 -
 sdks/python/apache_beam/transforms/window.py    |  3 +--
 .../apache_beam/transforms/window_test.py       |  9 ++++----
 .../transforms/write_ptransform_test.py         |  4 ++--
 sdks/python/apache_beam/typehints/decorators.py |  3 +--
 .../typehints/native_type_compatibility.py      |  1 +
 .../typehints/native_type_compatibility_test.py |  5 ++--
 sdks/python/apache_beam/typehints/opcodes.py    | 12 ++++++++--
 .../typehints/trivial_inference_test.py         |  1 -
 sdks/python/apache_beam/typehints/typecheck.py  |  6 ++---
 .../typehints/typed_pipeline_test.py            |  6 ++---
 sdks/python/apache_beam/typehints/typehints.py  |  1 -
 .../apache_beam/typehints/typehints_test.py     |  3 +--
 .../apache_beam/utils/annotations_test.py       |  1 +
 sdks/python/apache_beam/utils/counters.py       |  3 +--
 sdks/python/apache_beam/utils/processes_test.py |  1 -
 sdks/python/apache_beam/utils/retry_test.py     |  5 ++--
 sdks/python/apache_beam/utils/urns.py           |  1 -
 sdks/python/run_pylint.sh                       | 20 ++++++++++++++++
 161 files changed, 369 insertions(+), 384 deletions(-)
----------------------------------------------------------------------



Mime
View raw message