You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by dh...@apache.org on 2016/05/23 21:19:56 UTC

[2/2] incubator-beam git commit: Closes #371

Closes #371


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

Branch: refs/heads/master
Commit: 9934a43357e24455637a0477ff3ae74d721fe306
Parents: c913900 6a74143
Author: Dan Halperin <dh...@google.com>
Authored: Mon May 23 14:19:49 2016 -0700
Committer: Dan Halperin <dh...@google.com>
Committed: Mon May 23 14:19:49 2016 -0700

----------------------------------------------------------------------
 .../java/org/apache/beam/sdk/io/PubsubIO.java   |  11 +-
 .../apache/beam/sdk/io/PubsubUnboundedSink.java |   7 +-
 .../apache/beam/sdk/util/MovingFunction.java    |   8 +-
 .../beam/sdk/util/PubsubApiaryClient.java       | 304 ------------------
 .../org/apache/beam/sdk/util/PubsubClient.java  |   2 +-
 .../apache/beam/sdk/util/PubsubJsonClient.java  | 315 +++++++++++++++++++
 .../beam/sdk/io/PubsubUnboundedSourceTest.java  |   2 -
 .../beam/sdk/util/PubsubApiaryClientTest.java   | 132 --------
 .../beam/sdk/util/PubsubJsonClientTest.java     | 132 ++++++++
 9 files changed, 456 insertions(+), 457 deletions(-)
----------------------------------------------------------------------