This closes #2503
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/7e603d5c Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/7e603d5c Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/7e603d5c Branch: refs/heads/master Commit: 7e603d5c763ee4b95dffb94e129603de55e5c33d Parents: 82f2f2c 5bcb8c5 Author: Dan Halperin <[email protected]> Authored: Wed Apr 12 08:16:47 2017 -0700 Committer: Dan Halperin <[email protected]> Committed: Wed Apr 12 08:16:47 2017 -0700 ---------------------------------------------------------------------- .../beam/examples/complete/game/GameStats.java | 2 +- .../examples/complete/game/LeaderBoard.java | 2 +- .../triggers/AfterWatermarkStateMachine.java | 14 +- runners/google-cloud-dataflow-java/pom.xml | 5 +- .../beam/runners/dataflow/DataflowRunner.java | 4 +- sdks/java/core/pom.xml | 44 - .../java/org/apache/beam/sdk/io/PubsubIO.java | 1016 ------------ .../apache/beam/sdk/io/PubsubUnboundedSink.java | 494 ------ .../beam/sdk/io/PubsubUnboundedSource.java | 1463 ------------------ .../apache/beam/sdk/transforms/GroupByKey.java | 4 +- .../transforms/windowing/AfterWatermark.java | 14 +- .../org/apache/beam/sdk/util/PubsubClient.java | 544 ------- .../apache/beam/sdk/util/PubsubGrpcClient.java | 424 ----- .../apache/beam/sdk/util/PubsubJsonClient.java | 317 ---- .../apache/beam/sdk/util/PubsubTestClient.java | 436 ------ .../org/apache/beam/sdk/util/Transport.java | 3 +- .../org/apache/beam/sdk/io/PubsubIOTest.java | 189 --- .../beam/sdk/io/PubsubUnboundedSinkTest.java | 190 --- .../beam/sdk/io/PubsubUnboundedSourceTest.java | 411 ----- .../apache/beam/sdk/util/PubsubClientTest.java | 189 --- .../beam/sdk/util/PubsubGrpcClientTest.java | 207 --- .../beam/sdk/util/PubsubJsonClientTest.java | 140 -- .../beam/sdk/util/PubsubTestClientTest.java | 114 -- sdks/java/io/google-cloud-platform/pom.xml | 44 + .../beam/sdk/io/gcp/pubsub/PubsubClient.java | 544 +++++++ .../sdk/io/gcp/pubsub/PubsubGrpcClient.java | 424 +++++ .../apache/beam/sdk/io/gcp/pubsub/PubsubIO.java | 1014 ++++++++++++ .../sdk/io/gcp/pubsub/PubsubJsonClient.java | 319 ++++ .../sdk/io/gcp/pubsub/PubsubTestClient.java | 436 ++++++ .../sdk/io/gcp/pubsub/PubsubUnboundedSink.java | 490 ++++++ .../io/gcp/pubsub/PubsubUnboundedSource.java | 1463 ++++++++++++++++++ .../beam/sdk/io/gcp/pubsub/package-info.java | 24 + .../beam/sdk/io/gcp/GcpApiSurfaceTest.java | 5 +- .../sdk/io/gcp/pubsub/PubsubClientTest.java | 189 +++ .../sdk/io/gcp/pubsub/PubsubGrpcClientTest.java | 208 +++ .../beam/sdk/io/gcp/pubsub/PubsubIOTest.java | 189 +++ .../sdk/io/gcp/pubsub/PubsubJsonClientTest.java | 139 ++ .../sdk/io/gcp/pubsub/PubsubTestClientTest.java | 114 ++ .../io/gcp/pubsub/PubsubUnboundedSinkTest.java | 188 +++ .../gcp/pubsub/PubsubUnboundedSourceTest.java | 409 +++++ 40 files changed, 6218 insertions(+), 6207 deletions(-) ----------------------------------------------------------------------
