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/12/23 04:22:54 UTC
[4/4] incubator-beam git commit: Closes #1685
Closes #1685
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/9c37274d
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/9c37274d
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/9c37274d
Branch: refs/heads/python-sdk
Commit: 9c37274dd77362e09f12efe27f69b40c6a32519c
Parents: 82d7f0f fd5bf2c
Author: Robert Bradshaw <ro...@gmail.com>
Authored: Thu Dec 22 20:22:36 2016 -0800
Committer: Robert Bradshaw <ro...@gmail.com>
Committed: Thu Dec 22 20:22:36 2016 -0800
----------------------------------------------------------------------
sdks/python/README.md | 16 ++--
.../examples/complete/autocomplete_test.py | 2 +-
.../examples/complete/estimate_pi_test.py | 2 +-
.../examples/complete/juliaset/juliaset_main.py | 2 +-
.../apache_beam/examples/complete/tfidf_test.py | 2 +-
.../examples/complete/top_wikipedia_sessions.py | 4 +-
.../complete/top_wikipedia_sessions_test.py | 2 +-
.../cookbook/bigquery_side_input_test.py | 2 +-
.../cookbook/bigquery_tornadoes_test.py | 2 +-
.../examples/cookbook/coders_test.py | 2 +-
.../examples/cookbook/combiners_test.py | 4 +-
.../examples/cookbook/custom_ptransform_test.py | 2 +-
.../examples/cookbook/filters_test.py | 2 +-
.../examples/cookbook/multiple_output_pardo.py | 2 +-
.../apache_beam/examples/snippets/snippets.py | 10 +--
.../examples/snippets/snippets_test.py | 10 +--
.../apache_beam/examples/wordcount_debugging.py | 2 +-
.../apache_beam/examples/wordcount_minimal.py | 4 +-
.../apache_beam/internal/apiclient_test.py | 4 +-
sdks/python/apache_beam/io/avroio_test.py | 10 +--
.../python/apache_beam/io/concat_source_test.py | 2 +-
.../apache_beam/io/filebasedsource_test.py | 18 ++--
sdks/python/apache_beam/io/fileio_test.py | 10 +--
sdks/python/apache_beam/io/sources_test.py | 2 +-
sdks/python/apache_beam/io/textio_test.py | 24 +++---
sdks/python/apache_beam/pipeline.py | 2 +-
sdks/python/apache_beam/pipeline_test.py | 6 +-
sdks/python/apache_beam/pvalue_test.py | 4 +-
sdks/python/apache_beam/runners/__init__.py | 6 +-
.../apache_beam/runners/dataflow_runner.py | 14 +--
.../apache_beam/runners/direct/__init__.py | 2 +-
.../consumer_tracking_pipeline_visitor_test.py | 4 +-
.../apache_beam/runners/direct/direct_runner.py | 10 +--
.../runners/direct/evaluation_context.py | 4 +-
sdks/python/apache_beam/runners/runner.py | 28 ++++--
sdks/python/apache_beam/runners/runner_test.py | 37 +++++---
.../apache_beam/runners/template_runner_test.py | 8 +-
.../runners/test/test_dataflow_runner.py | 4 +-
sdks/python/apache_beam/test_pipeline.py | 2 +-
.../apache_beam/transforms/aggregator_test.py | 2 +-
.../apache_beam/transforms/combiners_test.py | 24 +++---
.../python/apache_beam/transforms/ptransform.py | 2 +-
.../apache_beam/transforms/ptransform_test.py | 90 ++++++++++----------
.../apache_beam/transforms/sideinputs_test.py | 2 +-
.../apache_beam/transforms/trigger_test.py | 6 +-
.../apache_beam/transforms/window_test.py | 8 +-
sdks/python/apache_beam/utils/options.py | 8 +-
.../utils/pipeline_options_validator.py | 4 +-
.../utils/pipeline_options_validator_test.py | 22 ++---
sdks/python/run_postcommit.sh | 4 +-
50 files changed, 233 insertions(+), 212 deletions(-)
----------------------------------------------------------------------