You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by bc...@apache.org on 2016/10/20 18:19:02 UTC
[3/3] incubator-beam git commit: Closes #1088
Closes #1088
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/5047cf74
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/5047cf74
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/5047cf74
Branch: refs/heads/master
Commit: 5047cf746f5040e54e840c0cf9898c41affe17bd
Parents: ff6301b ad03d07
Author: bchambers <bc...@google.com>
Authored: Thu Oct 20 11:10:27 2016 -0700
Committer: bchambers <bc...@google.com>
Committed: Thu Oct 20 11:10:27 2016 -0700
----------------------------------------------------------------------
.../core/UnboundedReadFromBoundedSource.java | 2 +-
runners/direct-java/pom.xml | 5 -
.../runners/direct/ForwardingPTransform.java | 2 +-
.../beam/runners/direct/DirectRunnerTest.java | 32 --
.../direct/ForwardingPTransformTest.java | 7 +-
.../beam/runners/dataflow/DataflowRunner.java | 5 +-
.../DataflowUnboundedReadFromBoundedSource.java | 4 +-
.../sdk/io/BoundedReadFromUnboundedSource.java | 5 +-
.../apache/beam/sdk/io/CompressedSource.java | 2 +-
.../java/org/apache/beam/sdk/io/PubsubIO.java | 5 +-
.../main/java/org/apache/beam/sdk/io/Read.java | 4 +-
.../main/java/org/apache/beam/sdk/io/Write.java | 6 +-
.../sdk/options/ProxyInvocationHandler.java | 149 +++---
.../org/apache/beam/sdk/transforms/Combine.java | 60 +--
.../apache/beam/sdk/transforms/CombineFns.java | 33 +-
.../beam/sdk/transforms/CombineWithContext.java | 3 +-
.../beam/sdk/transforms/DoFnAdapters.java | 2 +-
.../beam/sdk/transforms/FlatMapElements.java | 6 +-
.../apache/beam/sdk/transforms/MapElements.java | 8 +-
.../org/apache/beam/sdk/transforms/ParDo.java | 60 ++-
.../apache/beam/sdk/transforms/Partition.java | 2 +-
.../sdk/transforms/display/DisplayData.java | 518 +++++++++++++------
.../beam/sdk/transforms/windowing/Window.java | 2 +-
.../io/BoundedReadFromUnboundedSourceTest.java | 4 +-
.../beam/sdk/io/CompressedSourceTest.java | 4 +-
.../java/org/apache/beam/sdk/io/ReadTest.java | 10 +-
.../java/org/apache/beam/sdk/io/WriteTest.java | 6 +-
.../sdk/options/ProxyInvocationHandlerTest.java | 40 ++
.../beam/sdk/transforms/CombineFnsTest.java | 7 +-
.../apache/beam/sdk/transforms/CombineTest.java | 4 +-
.../apache/beam/sdk/transforms/ParDoTest.java | 8 +-
.../transforms/display/DisplayDataMatchers.java | 141 +++--
.../display/DisplayDataMatchersTest.java | 67 ++-
.../sdk/transforms/display/DisplayDataTest.java | 367 +++++++++----
.../sdk/transforms/windowing/WindowTest.java | 4 +-
.../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 5 -
.../beam/sdk/io/gcp/bigtable/BigtableIO.java | 2 +-
.../beam/sdk/io/gcp/datastore/DatastoreV1.java | 2 +-
38 files changed, 988 insertions(+), 605 deletions(-)
----------------------------------------------------------------------