beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dhalp...@apache.org
Subject [2/2] incubator-beam git commit: Closes #1230
Date Tue, 29 Nov 2016 05:21:50 GMT
Closes #1230


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

Branch: refs/heads/master
Commit: aeff1d5c219385cce20a275a4e47d9184f5cf59c
Parents: ae06f75 f922598
Author: Dan Halperin <dhalperi@google.com>
Authored: Mon Nov 28 21:21:35 2016 -0800
Committer: Dan Halperin <dhalperi@google.com>
Committed: Mon Nov 28 21:21:35 2016 -0800

----------------------------------------------------------------------
 .../java/org/apache/beam/sdk/io/PubsubIO.java   | 176 ++++++++++++++++---
 .../apache/beam/sdk/io/PubsubUnboundedSink.java |  23 ++-
 .../beam/sdk/io/PubsubUnboundedSource.java      |  40 +++--
 .../org/apache/beam/sdk/io/PubsubIOTest.java    |  43 +++--
 .../beam/sdk/io/PubsubUnboundedSinkTest.java    |  20 ++-
 .../beam/sdk/io/PubsubUnboundedSourceTest.java  |  14 +-
 6 files changed, 232 insertions(+), 84 deletions(-)
----------------------------------------------------------------------



Mime
View raw message