You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by tg...@apache.org on 2017/08/09 01:19:18 UTC
[2/2] beam git commit: This closes #3193
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(-)
----------------------------------------------------------------------