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 <kirpic...@google.com> Authored: Sat Apr 29 15:17:48 2017 -0700 Committer: Eugene Kirpichov <kirpic...@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(-) ----------------------------------------------------------------------