This closes #3193
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/9ed2cf41 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/9ed2cf41 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/9ed2cf41 Branch: refs/heads/master Commit: 9ed2cf41f1f068b3b27e9a814d6f7ceed3406dbf Parents: f5714f2 2b9b050 Author: Thomas Groh <tg...@google.com> Authored: Tue Aug 8 18:19:00 2017 -0700 Committer: Thomas Groh <tg...@google.com> Committed: Tue Aug 8 18:19:00 2017 -0700 ---------------------------------------------------------------------- .../core/construction/CoderTranslation.java | 16 +--- .../core/construction/CombineTranslation.java | 28 ++---- .../CreatePCollectionViewTranslation.java | 17 +--- .../construction/PTransformTranslation.java | 12 +-- .../core/construction/ParDoTranslation.java | 58 +++++------- .../core/construction/PipelineTranslation.java | 12 +-- .../core/construction/ReadTranslation.java | 56 +++++------ .../construction/TestStreamTranslation.java | 5 +- .../construction/WindowIntoTranslation.java | 9 +- .../WindowingStrategyTranslation.java | 97 ++++++++------------ .../construction/WriteFilesTranslation.java | 29 +++--- .../CreatePCollectionViewTranslationTest.java | 6 +- .../core/construction/ParDoTranslationTest.java | 3 +- .../construction/TestStreamTranslationTest.java | 4 +- .../src/main/proto/beam_runner_api.proto | 5 +- .../beam/fn/harness/BeamFnDataReadRunner.java | 4 +- .../beam/fn/harness/BeamFnDataWriteRunner.java | 4 +- .../beam/fn/harness/BoundedSourceRunner.java | 10 +- .../apache/beam/fn/harness/FnApiDoFnRunner.java | 10 +- .../fn/harness/BeamFnDataReadRunnerTest.java | 5 +- .../fn/harness/BeamFnDataWriteRunnerTest.java | 5 +- .../fn/harness/BoundedSourceRunnerTest.java | 18 ++-- .../beam/fn/harness/FnApiDoFnRunnerTest.java | 13 +-- sdks/python/apache_beam/coders/coders.py | 11 +-- .../runners/portability/fn_api_runner.py | 78 ++++++++++------ .../runners/worker/bundle_processor.py | 21 ++--- sdks/python/apache_beam/transforms/core.py | 10 +- .../python/apache_beam/transforms/ptransform.py | 6 +- sdks/python/apache_beam/utils/proto_utils.py | 11 +++ sdks/python/apache_beam/utils/urns.py | 6 +- 30 files changed, 250 insertions(+), 319 deletions(-) ----------------------------------------------------------------------