Repository: incubator-beam Updated Branches: refs/heads/master cc64d654c -> 3edae9b8b
Closes #332 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/3edae9b8 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/3edae9b8 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/3edae9b8 Branch: refs/heads/master Commit: 3edae9b8b4d7afefb5c803c19bb0a1c21ebba89d Parents: cc64d65 f55fb88 Author: Dan Halperin <dhalp...@google.com> Authored: Tue May 17 10:49:22 2016 -0700 Committer: Dan Halperin <dhalp...@google.com> Committed: Tue May 17 11:08:13 2016 -0700 ---------------------------------------------------------------------- .../apache/beam/sdk/io/PubsubUnboundedSink.java | 1 + .../beam/sdk/io/PubsubUnboundedSource.java | 1206 ++++++++++++++++++ .../apache/beam/sdk/util/BucketingFunction.java | 153 +++ .../apache/beam/sdk/util/MovingFunction.java | 153 +++ .../beam/sdk/util/PubsubApiaryClient.java | 7 + .../org/apache/beam/sdk/util/PubsubClient.java | 9 + .../apache/beam/sdk/util/PubsubGrpcClient.java | 9 + .../apache/beam/sdk/util/PubsubTestClient.java | 398 +++--- .../beam/sdk/io/PubsubUnboundedSinkTest.java | 78 +- .../beam/sdk/io/PubsubUnboundedSourceTest.java | 324 +++++ .../beam/sdk/util/BucketingFunctionTest.java | 104 ++ .../beam/sdk/util/MovingFunctionTest.java | 115 ++ .../beam/sdk/util/PubsubTestClientTest.java | 81 +- 13 files changed, 2414 insertions(+), 224 deletions(-) ----------------------------------------------------------------------
