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 <[email protected]> Authored: Thu Oct 20 11:10:27 2016 -0700 Committer: bchambers <[email protected]> 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(-) ----------------------------------------------------------------------
