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 2017/01/20 22:58:26 UTC
[3/3] beam git commit: Closes #1358
Closes #1358
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/c6e46b65
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/c6e46b65
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/c6e46b65
Branch: refs/heads/master
Commit: c6e46b655f3a3a1c6003e1bccdb52ae50efa2882
Parents: a681037 f032fac
Author: Dan Halperin <dh...@google.com>
Authored: Fri Jan 20 14:57:57 2017 -0800
Committer: Dan Halperin <dh...@google.com>
Committed: Fri Jan 20 14:57:57 2017 -0800
----------------------------------------------------------------------
.../beam/examples/complete/game/GameStats.java | 5 +-
.../examples/complete/game/LeaderBoard.java | 5 +-
.../beam/runners/dataflow/DataflowRunner.java | 30 +-
.../java/org/apache/beam/sdk/io/PubsubIO.java | 783 +++++++++----------
.../apache/beam/sdk/io/PubsubUnboundedSink.java | 72 +-
.../beam/sdk/io/PubsubUnboundedSource.java | 67 +-
.../apache/beam/sdk/transforms/GroupByKey.java | 2 +-
.../org/apache/beam/sdk/util/PropertyNames.java | 1 +
.../org/apache/beam/sdk/util/PubsubClient.java | 28 +-
.../apache/beam/sdk/util/PubsubGrpcClient.java | 6 +-
.../apache/beam/sdk/util/PubsubJsonClient.java | 4 +-
.../apache/beam/sdk/util/PubsubTestClient.java | 6 +-
.../org/apache/beam/sdk/io/PubsubIOTest.java | 41 +-
.../beam/sdk/io/PubsubUnboundedSinkTest.java | 41 +-
.../beam/sdk/io/PubsubUnboundedSourceTest.java | 10 +-
.../beam/sdk/util/PubsubGrpcClientTest.java | 8 +-
.../beam/sdk/util/PubsubJsonClientTest.java | 3 +-
.../beam/sdk/util/PubsubTestClientTest.java | 4 +-
18 files changed, 643 insertions(+), 473 deletions(-)
----------------------------------------------------------------------