[BEAM-151] This closes #87
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/6467afb7 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/6467afb7 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/6467afb7 Branch: refs/heads/master Commit: 6467afb74b1b37cccc3f4210a08e75e678612010 Parents: 7f0a2f7 ac1dd43 Author: Luke Cwik <[email protected]> Authored: Thu Apr 7 11:20:55 2016 -0700 Committer: Luke Cwik <[email protected]> Committed: Thu Apr 7 11:20:55 2016 -0700 ---------------------------------------------------------------------- .../cloud/dataflow/sdk/io/DatastoreIO.java | 14 +- .../google/cloud/dataflow/sdk/io/PubsubIO.java | 14 +- .../google/cloud/dataflow/sdk/io/TextIO.java | 10 +- .../options/DataflowPipelineDebugOptions.java | 13 +- .../sdk/options/DataflowPipelineOptions.java | 2 +- .../dataflow/sdk/options/PubsubOptions.java | 36 ++++ .../sdk/runners/DataflowPipelineRunner.java | 6 +- .../dataflow/sdk/util/DataflowTransport.java | 112 ++++++++++ .../cloud/dataflow/sdk/util/Transport.java | 65 +----- .../dataflow/sdk/io/DataflowTextIOTest.java | 118 +++++++++++ .../cloud/dataflow/sdk/io/DatastoreIOTest.java | 66 +----- .../cloud/dataflow/sdk/io/TextIOTest.java | 79 +------ .../sdk/options/GoogleApiDebugOptionsTest.java | 93 +++++---- .../sdk/options/PipelineOptionsFactoryTest.java | 11 +- .../dataflow/sdk/testing/TestPipelineTest.java | 32 +-- .../sdk/transforms/DataflowGroupByKeyTest.java | 111 ++++++++++ .../sdk/transforms/DataflowViewTest.java | 206 +++++++++++++++++++ .../dataflow/sdk/transforms/GroupByKeyTest.java | 62 ------ .../cloud/dataflow/sdk/transforms/ViewTest.java | 126 ------------ 19 files changed, 678 insertions(+), 498 deletions(-) ----------------------------------------------------------------------
