You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by jk...@apache.org on 2017/04/29 22:32:01 UTC
[9/9] beam git commit: This closes #2750
This closes #2750
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/14d60b26
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/14d60b26
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/14d60b26
Branch: refs/heads/master
Commit: 14d60b26e7e9b8a578038599341e66ccd99d012b
Parents: f5e3f52 8853d53
Author: Eugene Kirpichov <ki...@google.com>
Authored: Sat Apr 29 15:17:48 2017 -0700
Committer: Eugene Kirpichov <ki...@google.com>
Committed: Sat Apr 29 15:17:48 2017 -0700
----------------------------------------------------------------------
.../beam/examples/complete/game/GameStats.java | 6 +-
.../examples/complete/game/LeaderBoard.java | 6 +-
.../beam/runners/dataflow/DataflowRunner.java | 18 +-
.../org/apache/beam/sdk/util/PropertyNames.java | 4 +-
.../beam/sdk/io/gcp/pubsub/PubsubClient.java | 42 +-
.../sdk/io/gcp/pubsub/PubsubGrpcClient.java | 36 +-
.../apache/beam/sdk/io/gcp/pubsub/PubsubIO.java | 508 +++++++++----------
.../sdk/io/gcp/pubsub/PubsubJsonClient.java | 36 +-
.../sdk/io/gcp/pubsub/PubsubTestClient.java | 6 +-
.../sdk/io/gcp/pubsub/PubsubUnboundedSink.java | 58 ++-
.../io/gcp/pubsub/PubsubUnboundedSource.java | 65 ++-
.../sdk/io/gcp/pubsub/PubsubClientTest.java | 50 +-
.../sdk/io/gcp/pubsub/PubsubGrpcClientTest.java | 16 +-
.../beam/sdk/io/gcp/pubsub/PubsubIOTest.java | 78 +--
.../sdk/io/gcp/pubsub/PubsubJsonClientTest.java | 14 +-
.../io/gcp/pubsub/PubsubUnboundedSinkTest.java | 10 +-
.../gcp/pubsub/PubsubUnboundedSourceTest.java | 6 +-
17 files changed, 459 insertions(+), 500 deletions(-)
----------------------------------------------------------------------