beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From lc...@apache.org
Subject [2/2] beam git commit: [BEAM-2354] Add a ReadStringsFromPubSub/WriteStringsToPubSub PTransform
Date Fri, 26 May 2017 02:24:12 GMT
[BEAM-2354] Add a ReadStringsFromPubSub/WriteStringsToPubSub PTransform

This closes #3223


Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/50200f23
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/50200f23
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/50200f23

Branch: refs/heads/master
Commit: 50200f23a87d64abf492ed27fed03d31ed0b64ca
Parents: 7bb10a6 14329b8
Author: Luke Cwik <lcwik@google.com>
Authored: Thu May 25 19:23:53 2017 -0700
Committer: Luke Cwik <lcwik@google.com>
Committed: Thu May 25 19:23:53 2017 -0700

----------------------------------------------------------------------
 .../apache_beam/examples/streaming_wordcap.py   |  6 +-
 .../apache_beam/examples/streaming_wordcount.py |  6 +-
 sdks/python/apache_beam/io/gcp/pubsub.py        | 87 ++++++++++++++++----
 sdks/python/apache_beam/io/gcp/pubsub_test.py   | 57 +++++++++++--
 .../runners/dataflow/dataflow_runner.py         |  8 +-
 5 files changed, 132 insertions(+), 32 deletions(-)
----------------------------------------------------------------------



Mime
View raw message