beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From j...@apache.org
Subject [9/9] beam git commit: This closes #2750
Date Sat, 29 Apr 2017 22:32:01 GMT
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 <kirpichov@google.com>
Authored: Sat Apr 29 15:17:48 2017 -0700
Committer: Eugene Kirpichov <kirpichov@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(-)
----------------------------------------------------------------------



Mime
View raw message