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 <dhalp...@google.com> Authored: Mon Nov 28 21:21:35 2016 -0800 Committer: Dan Halperin <dhalp...@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(-) ----------------------------------------------------------------------
