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 2017/01/18 18:11:38 UTC
[6/6] beam git commit: Closes #1762
Closes #1762
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/36a7d349
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/36a7d349
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/36a7d349
Branch: refs/heads/python-sdk
Commit: 36a7d3491b4929f7539f2aa620b4ad25865036f6
Parents: f25c0e4 2197009
Author: Robert Bradshaw <ro...@gmail.com>
Authored: Wed Jan 18 10:10:50 2017 -0800
Committer: Robert Bradshaw <ro...@gmail.com>
Committed: Wed Jan 18 10:10:50 2017 -0800
----------------------------------------------------------------------
.../examples/complete/autocomplete_test.py | 3 +-
.../examples/complete/estimate_pi_test.py | 4 +-
.../complete/juliaset/juliaset/juliaset.py | 2 +-
.../complete/juliaset/juliaset/juliaset_test.py | 2 +-
.../examples/complete/juliaset/juliaset_main.py | 2 +-
.../apache_beam/examples/complete/tfidf.py | 3 +-
.../apache_beam/examples/complete/tfidf_test.py | 3 +-
.../examples/complete/top_wikipedia_sessions.py | 2 +-
.../complete/top_wikipedia_sessions_test.py | 3 +-
.../cookbook/bigquery_side_input_test.py | 3 +-
.../cookbook/bigquery_tornadoes_test.py | 2 +-
.../apache_beam/examples/cookbook/bigshuffle.py | 2 +-
.../examples/cookbook/bigshuffle_test.py | 2 +-
.../examples/cookbook/coders_test.py | 3 +-
.../examples/cookbook/combiners_test.py | 5 +-
.../examples/cookbook/custom_ptransform.py | 4 +-
.../examples/cookbook/custom_ptransform_test.py | 3 +-
.../examples/cookbook/datastore_wordcount.py | 7 +-
.../examples/cookbook/filters_test.py | 3 +-
.../examples/cookbook/group_with_coder.py | 2 +-
.../examples/cookbook/group_with_coder_test.py | 4 +-
.../examples/cookbook/mergecontacts.py | 2 +-
.../examples/cookbook/mergecontacts_test.py | 3 +-
.../examples/cookbook/multiple_output_pardo.py | 4 +-
.../cookbook/multiple_output_pardo_test.py | 2 +-
.../apache_beam/examples/snippets/snippets.py | 62 ++++++-------
.../examples/snippets/snippets_test.py | 12 +--
.../apache_beam/examples/streaming_wordcap.py | 2 +-
.../apache_beam/examples/streaming_wordcount.py | 2 +-
sdks/python/apache_beam/examples/wordcount.py | 1 +
.../apache_beam/examples/wordcount_debugging.py | 4 +-
.../apache_beam/examples/wordcount_minimal.py | 4 +-
.../python/apache_beam/io/concat_source_test.py | 3 +-
.../apache_beam/io/filebasedsource_test.py | 19 ++--
sdks/python/apache_beam/io/fileio_test.py | 11 +--
sdks/python/apache_beam/io/sources_test.py | 3 +-
sdks/python/apache_beam/io/textio_test.py | 26 +++---
sdks/python/apache_beam/pipeline.py | 2 +-
sdks/python/apache_beam/pipeline_test.py | 13 +--
.../apache_beam/runners/dataflow_runner.py | 60 +++++++++----
.../apache_beam/runners/direct/direct_runner.py | 15 ++--
sdks/python/apache_beam/runners/runner.py | 35 +++++++-
sdks/python/apache_beam/runners/runner_test.py | 1 +
.../apache_beam/runners/template_runner_test.py | 4 +-
.../runners/test/test_dataflow_runner.py | 4 +-
sdks/python/apache_beam/test_pipeline.py | 11 ++-
.../apache_beam/tests/pipeline_verifiers.py | 4 +-
.../apache_beam/transforms/aggregator_test.py | 3 +-
.../apache_beam/transforms/combiners_test.py | 26 +++---
.../python/apache_beam/transforms/ptransform.py | 2 +-
.../apache_beam/transforms/ptransform_test.py | 93 ++++++++++----------
.../apache_beam/transforms/window_test.py | 10 +--
.../transforms/write_ptransform_test.py | 5 +-
.../typehints/typed_pipeline_test.py | 6 +-
.../apache_beam/utils/pipeline_options.py | 3 +-
sdks/python/run_postcommit.sh | 2 +-
sdks/python/tox.ini | 3 +
57 files changed, 304 insertions(+), 222 deletions(-)
----------------------------------------------------------------------