beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From lc...@apache.org
Subject [12/12] incubator-beam git commit: [BEAM-151] This closes #87
Date Thu, 07 Apr 2016 18:21:22 GMT
[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 <lcwik@google.com>
Authored: Thu Apr 7 11:20:55 2016 -0700
Committer: Luke Cwik <lcwik@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(-)
----------------------------------------------------------------------



Mime
View raw message