This closes #2545
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/eb2e6aa4 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/eb2e6aa4 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/eb2e6aa4 Branch: refs/heads/master Commit: eb2e6aa4f6ea8b93da4401b8dbb952fc25981ea1 Parents: 3076c86 f774958 Author: Ahmet Altay <[email protected]> Authored: Tue Apr 18 15:30:09 2017 -0700 Committer: Ahmet Altay <[email protected]> Committed: Tue Apr 18 15:30:09 2017 -0700 ---------------------------------------------------------------------- sdks/python/apache_beam/error.py | 4 + sdks/python/apache_beam/examples/wordcount.py | 32 ++-- .../apache_beam/internal/gcp/json_value.py | 6 + sdks/python/apache_beam/io/filebasedsource.py | 53 +++++-- .../apache_beam/io/filebasedsource_test.py | 23 +++ sdks/python/apache_beam/io/fileio.py | 54 +++++-- sdks/python/apache_beam/io/fileio_test.py | 45 ++++-- .../runners/dataflow/dataflow_runner.py | 6 + .../runners/dataflow/internal/apiclient.py | 1 + .../apache_beam/runners/direct/direct_runner.py | 6 + sdks/python/apache_beam/transforms/display.py | 1 + .../apache_beam/transforms/display_test.py | 36 +++++ .../apache_beam/utils/pipeline_options.py | 78 +++++++++- .../apache_beam/utils/pipeline_options_test.py | 52 ++++++- sdks/python/apache_beam/utils/value_provider.py | 103 +++++++++++++ .../apache_beam/utils/value_provider_test.py | 145 +++++++++++++++++++ 16 files changed, 582 insertions(+), 63 deletions(-) ----------------------------------------------------------------------
