Repository: incubator-beam Updated Branches: refs/heads/master 3f0eead50 -> 1ef53b17d
Closes #213 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/1ef53b17 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/1ef53b17 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/1ef53b17 Branch: refs/heads/master Commit: 1ef53b17d33016c99aab67ceb3a942e3da92e225 Parents: 3f0eead 2c509a8 Author: Dan Halperin <[email protected]> Authored: Wed May 4 08:22:47 2016 -0700 Committer: Dan Halperin <[email protected]> Committed: Wed May 4 08:22:47 2016 -0700 ---------------------------------------------------------------------- .../org/apache/beam/sdk/io/PubsubClient.java | 323 ------------ .../apache/beam/sdk/io/PubsubGrpcClient.java | 403 --------------- .../java/org/apache/beam/sdk/io/PubsubIO.java | 252 ++++------ .../beam/sdk/util/PubsubApiaryClient.java | 293 +++++++++++ .../org/apache/beam/sdk/util/PubsubClient.java | 489 +++++++++++++++++++ .../apache/beam/sdk/util/PubsubGrpcClient.java | 433 ++++++++++++++++ .../apache/beam/sdk/util/PubsubTestClient.java | 291 +++++++++++ .../org/apache/beam/sdk/util/Transport.java | 4 + .../org/apache/beam/sdk/io/PubsubIOTest.java | 157 ------ .../beam/sdk/util/PubsubApiaryClientTest.java | 134 +++++ .../apache/beam/sdk/util/PubsubClientTest.java | 189 +++++++ .../beam/sdk/util/PubsubGrpcClientTest.java | 170 +++++++ .../beam/sdk/util/PubsubTestClientTest.java | 97 ++++ 13 files changed, 2205 insertions(+), 1030 deletions(-) ----------------------------------------------------------------------
