You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ro...@apache.org on 2016/07/23 23:47:18 UTC
[12/12] incubator-beam git commit: Closes #718
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 <ro...@gmail.com>
Authored: Sat Jul 23 16:43:47 2016 -0700
Committer: Robert Bradshaw <ro...@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(-)
----------------------------------------------------------------------