Closes #718
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/38d9dea2 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/38d9dea2 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/38d9dea2 Branch: refs/heads/python-sdk Commit: 38d9dea2e62af280e4b9c258cedee70d6bcaa8ca Parents: 9fe102a e3c078f Author: Robert Bradshaw <rober...@gmail.com> Authored: Sat Jul 23 16:43:47 2016 -0700 Committer: Robert Bradshaw <rober...@gmail.com> Committed: Sat Jul 23 16:43:47 2016 -0700 ---------------------------------------------------------------------- sdks/python/apache_beam/dataflow_test.py | 99 ++-- .../examples/complete/autocomplete.py | 16 +- .../examples/complete/autocomplete_test.py | 4 +- .../examples/complete/estimate_pi.py | 14 +- .../examples/complete/estimate_pi_test.py | 2 +- .../complete/juliaset/juliaset/juliaset.py | 11 +- .../apache_beam/examples/complete/tfidf.py | 32 +- .../apache_beam/examples/complete/tfidf_test.py | 2 +- .../examples/complete/top_wikipedia_sessions.py | 8 +- .../complete/top_wikipedia_sessions_test.py | 2 +- .../examples/cookbook/bigquery_schema.py | 4 +- .../examples/cookbook/bigquery_side_input.py | 18 +- .../cookbook/bigquery_side_input_test.py | 12 +- .../examples/cookbook/bigquery_tornadoes.py | 10 +- .../cookbook/bigquery_tornadoes_test.py | 2 +- .../apache_beam/examples/cookbook/bigshuffle.py | 31 +- .../apache_beam/examples/cookbook/coders.py | 2 +- .../examples/cookbook/coders_test.py | 4 +- .../examples/cookbook/custom_ptransform.py | 9 +- .../examples/cookbook/custom_ptransform_test.py | 2 +- .../apache_beam/examples/cookbook/filters.py | 14 +- .../examples/cookbook/filters_test.py | 2 +- .../examples/cookbook/group_with_coder.py | 9 +- .../examples/cookbook/mergecontacts.py | 8 +- .../examples/cookbook/multiple_output_pardo.py | 30 +- .../apache_beam/examples/snippets/snippets.py | 69 ++- .../examples/snippets/snippets_test.py | 16 +- .../apache_beam/examples/streaming_wordcap.py | 6 +- .../apache_beam/examples/streaming_wordcount.py | 8 +- sdks/python/apache_beam/examples/wordcount.py | 16 +- .../apache_beam/examples/wordcount_debugging.py | 18 +- .../apache_beam/examples/wordcount_minimal.py | 16 +- sdks/python/apache_beam/io/avroio.py | 2 +- sdks/python/apache_beam/io/bigquery.py | 4 +- .../apache_beam/io/filebasedsource_test.py | 4 +- sdks/python/apache_beam/io/iobase.py | 4 +- sdks/python/apache_beam/pipeline.py | 13 + sdks/python/apache_beam/pipeline_test.py | 48 +- sdks/python/apache_beam/pvalue_test.py | 6 +- .../consumer_tracking_pipeline_visitor_test.py | 4 +- sdks/python/apache_beam/runners/runner_test.py | 6 +- .../apache_beam/transforms/combiners_test.py | 64 ++- sdks/python/apache_beam/transforms/core.py | 21 +- .../python/apache_beam/transforms/ptransform.py | 9 +- .../apache_beam/transforms/ptransform_test.py | 521 ++++++++++--------- sdks/python/apache_beam/transforms/util.py | 9 +- .../apache_beam/transforms/window_test.py | 14 +- .../transforms/write_ptransform_test.py | 2 +- .../typehints/typed_pipeline_test.py | 16 +- 49 files changed, 628 insertions(+), 615 deletions(-) ----------------------------------------------------------------------
