Closes #3086
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/1b31167f Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/1b31167f Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/1b31167f Branch: refs/heads/master Commit: 1b31167fb8bac634d40e5ab5b86b0e928e00f309 Parents: 4a62fab 0b7356e Author: Robert Bradshaw <[email protected]> Authored: Thu May 11 15:27:59 2017 -0700 Committer: Robert Bradshaw <[email protected]> Committed: Thu May 11 15:27:59 2017 -0700 ---------------------------------------------------------------------- .../examples/complete/autocomplete_test.py | 4 +- .../examples/complete/estimate_pi_test.py | 4 +- .../complete/game/hourly_team_score_test.py | 4 +- .../examples/complete/game/user_score_test.py | 4 +- .../apache_beam/examples/complete/tfidf_test.py | 4 +- .../complete/top_wikipedia_sessions_test.py | 4 +- .../cookbook/bigquery_side_input_test.py | 4 +- .../cookbook/bigquery_tornadoes_test.py | 6 +- .../examples/cookbook/coders_test.py | 4 +- .../examples/cookbook/combiners_test.py | 6 +- .../examples/cookbook/custom_ptransform_test.py | 4 +- .../examples/cookbook/filters_test.py | 12 ++- .../examples/cookbook/mergecontacts.py | 14 +-- .../apache_beam/examples/snippets/snippets.py | 17 +-- .../examples/snippets/snippets_test.py | 30 +++--- .../apache_beam/examples/wordcount_debugging.py | 6 +- sdks/python/apache_beam/io/avroio_test.py | 4 +- .../python/apache_beam/io/concat_source_test.py | 4 +- .../apache_beam/io/filebasedsource_test.py | 4 +- sdks/python/apache_beam/io/sources_test.py | 4 +- sdks/python/apache_beam/io/textio_test.py | 5 +- sdks/python/apache_beam/io/tfrecordio_test.py | 24 +++-- sdks/python/apache_beam/pipeline_test.py | 4 +- .../portability/maptask_executor_runner_test.py | 6 +- sdks/python/apache_beam/runners/runner_test.py | 4 +- sdks/python/apache_beam/testing/util.py | 107 +++++++++++++++++++ sdks/python/apache_beam/testing/util_test.py | 50 +++++++++ .../apache_beam/transforms/combiners_test.py | 2 +- .../apache_beam/transforms/create_test.py | 3 +- .../apache_beam/transforms/ptransform_test.py | 2 +- .../apache_beam/transforms/sideinputs_test.py | 2 +- .../apache_beam/transforms/trigger_test.py | 2 +- sdks/python/apache_beam/transforms/util.py | 79 -------------- sdks/python/apache_beam/transforms/util_test.py | 50 --------- .../apache_beam/transforms/window_test.py | 2 +- .../transforms/write_ptransform_test.py | 2 +- .../typehints/typed_pipeline_test.py | 2 +- 37 files changed, 271 insertions(+), 218 deletions(-) ----------------------------------------------------------------------
