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 <[email protected]> Authored: Thu May 19 18:27:15 2016 -0700 Committer: Dan Halperin <[email protected]> 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(-) ----------------------------------------------------------------------
