You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by dh...@apache.org on 2016/05/20 01:27:19 UTC
incubator-beam git commit: Closes #346
Repository: incubator-beam
Updated Branches:
refs/heads/master 26941f152 -> d0b9ca910
Closes #346
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/d0b9ca91
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/d0b9ca91
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/d0b9ca91
Branch: refs/heads/master
Commit: d0b9ca910efb5f8d2e2feb43ef586f8364b9541d
Parents: 662e493 26941f1
Author: Dan Halperin <dh...@google.com>
Authored: Thu May 19 18:27:15 2016 -0700
Committer: Dan Halperin <dh...@google.com>
Committed: Thu May 19 18:27:15 2016 -0700
----------------------------------------------------------------------
.../dataflow/DataflowPipelineRunner.java | 249 ++++++++++++++++---
.../dataflow/DataflowPipelineTranslator.java | 8 -
.../dataflow/internal/PubsubIOTranslator.java | 108 --------
.../dataflow/io/DataflowPubsubIOTest.java | 13 +-
.../java/org/apache/beam/sdk/io/PubsubIO.java | 102 +++++---
.../apache/beam/sdk/io/PubsubUnboundedSink.java | 67 ++++-
.../beam/sdk/io/PubsubUnboundedSource.java | 131 ++++++++--
.../beam/sdk/util/PubsubApiaryClient.java | 20 +-
.../org/apache/beam/sdk/util/PubsubClient.java | 82 ++++--
.../apache/beam/sdk/util/PubsubGrpcClient.java | 19 +-
.../apache/beam/sdk/util/PubsubTestClient.java | 21 +-
.../beam/sdk/io/PubsubUnboundedSinkTest.java | 48 ++--
.../beam/sdk/io/PubsubUnboundedSourceTest.java | 8 +-
.../beam/sdk/util/PubsubApiaryClientTest.java | 12 +-
.../beam/sdk/util/PubsubGrpcClientTest.java | 12 +-
.../beam/sdk/util/PubsubTestClientTest.java | 12 +-
16 files changed, 604 insertions(+), 308 deletions(-)
----------------------------------------------------------------------