This closes #325
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/c0efe568 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/c0efe568 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/c0efe568 Branch: refs/heads/master Commit: c0efe568e5291298c1394016a12e7979b37afc44 Parents: 9b5cf32 6269b8f Author: bchambers <[email protected]> Authored: Mon May 16 09:55:52 2016 -0700 Committer: bchambers <[email protected]> Committed: Mon May 16 09:55:52 2016 -0700 ---------------------------------------------------------------------- runners/google-cloud-dataflow-java/pom.xml | 10 +++ .../runners/dataflow/io/DataflowAvroIOTest.java | 69 ++++++++++++++++++++ .../dataflow/io/DataflowBigQueryIOTest.java | 29 +++++++- .../dataflow/io/DataflowDatastoreIOTest.java | 63 ++++++++++++++++++ .../dataflow/io/DataflowPubsubIOTest.java | 62 ++++++++++++++++++ .../runners/dataflow/io/DataflowTextIOTest.java | 15 ++++- .../DataflowDisplayDataEvaluator.java | 3 +- .../java/org/apache/beam/sdk/io/BigQueryIO.java | 11 ++++ .../java/org/apache/beam/sdk/io/PubsubIO.java | 5 ++ .../org/apache/beam/sdk/io/BigQueryIOTest.java | 6 +- .../beam/sdk/io/CompressedSourceTest.java | 3 +- .../sdk/options/ProxyInvocationHandlerTest.java | 6 +- .../sdk/transforms/ApproximateUniqueTest.java | 3 +- .../display/DisplayDataEvaluator.java | 28 ++++---- .../display/DisplayDataEvaluatorTest.java | 24 ++++++- .../transforms/display/DisplayDataMatchers.java | 8 +++ .../display/DisplayDataMatchersTest.java | 3 +- .../sdk/transforms/windowing/WindowTest.java | 4 +- .../sdk/io/gcp/bigtable/BigtableIOTest.java | 9 +-- 19 files changed, 316 insertions(+), 45 deletions(-) ----------------------------------------------------------------------
