You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by lc...@apache.org on 2016/04/07 20:21:22 UTC
[12/12] incubator-beam git commit: [BEAM-151] This closes #87
[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 <lc...@google.com>
Authored: Thu Apr 7 11:20:55 2016 -0700
Committer: Luke Cwik <lc...@google.com>
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(-)
----------------------------------------------------------------------