You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2017/06/30 21:31:36 UTC
[34/50] beam git commit: This closes #3454
This closes #3454
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/2dd1907c
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/2dd1907c
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/2dd1907c
Branch: refs/heads/gearpump-runner
Commit: 2dd1907c65cdd04f2a54f2ef1368ee39f72c19fe
Parents: 4d41e25 fb7ec28
Author: Ahmet Altay <al...@google.com>
Authored: Thu Jun 29 09:46:07 2017 -0700
Committer: Ahmet Altay <al...@google.com>
Committed: Thu Jun 29 09:46:07 2017 -0700
----------------------------------------------------------------------
.../apache_beam/examples/streaming_wordcount.py | 12 ++-
sdks/python/apache_beam/io/gcp/pubsub.py | 91 +++++++++++++++-----
sdks/python/apache_beam/io/gcp/pubsub_test.py | 89 +++++++++++--------
.../runners/dataflow/dataflow_runner.py | 11 +--
.../apache_beam/runners/direct/direct_runner.py | 54 ++++++++++++
.../runners/direct/transform_evaluator.py | 89 +++++++++++++++++++
6 files changed, 281 insertions(+), 65 deletions(-)
----------------------------------------------------------------------