Repository: incubator-beam Updated Branches: refs/heads/master 123674f4b -> 2fbc0ea3a
Closes #171 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/2fbc0ea3 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/2fbc0ea3 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/2fbc0ea3 Branch: refs/heads/master Commit: 2fbc0ea3adb63363952a6bb3d89733dd1b5cf961 Parents: 123674f 040f8f9 Author: Dan Halperin <[email protected]> Authored: Thu May 12 09:56:52 2016 -0700 Committer: Dan Halperin <[email protected]> Committed: Thu May 12 09:56:52 2016 -0700 ---------------------------------------------------------------------- .../apache/beam/sdk/io/PubsubUnboundedSink.java | 392 +++++++++++++++++++ .../beam/sdk/util/PubsubApiaryClient.java | 14 +- .../org/apache/beam/sdk/util/PubsubClient.java | 19 +- .../apache/beam/sdk/util/PubsubGrpcClient.java | 59 +-- .../apache/beam/sdk/util/PubsubTestClient.java | 10 + .../beam/sdk/io/PubsubUnboundedSinkTest.java | 145 +++++++ 6 files changed, 612 insertions(+), 27 deletions(-) ----------------------------------------------------------------------
