This closes #2471
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/84a96297 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/84a96297 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/84a96297 Branch: refs/heads/master Commit: 84a96297c4f790249890cd41775472240181cb62 Parents: c58f4f8 5f7c772 Author: Dan Halperin <[email protected]> Authored: Tue Apr 11 05:11:44 2017 -0700 Committer: Dan Halperin <[email protected]> Committed: Tue Apr 11 05:11:44 2017 -0700 ---------------------------------------------------------------------- .../beam/runners/dataflow/DataflowRunner.java | 11 - .../java/org/apache/beam/sdk/io/PubsubIO.java | 219 ++----------------- .../org/apache/beam/sdk/io/PubsubIOTest.java | 12 +- 3 files changed, 22 insertions(+), 220 deletions(-) ----------------------------------------------------------------------
