You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by jb...@apache.org on 2017/04/12 19:57:06 UTC
[35/50] [abbrv] beam git commit: This closes #2503
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/DSL_SQL
Commit: 7e603d5c763ee4b95dffb94e129603de55e5c33d
Parents: 82f2f2c 5bcb8c5
Author: Dan Halperin <dh...@google.com>
Authored: Wed Apr 12 08:16:47 2017 -0700
Committer: Dan Halperin <dh...@google.com>
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(-)
----------------------------------------------------------------------