This closes #361
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/bde2a856 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/bde2a856 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/bde2a856 Branch: refs/heads/master Commit: bde2a856f1652f6ebab7aae2d5e78eeb4683a15a Parents: 9f97ea0 928a302 Author: Kenneth Knowles <k...@google.com> Authored: Wed May 25 14:16:54 2016 -0700 Committer: Kenneth Knowles <k...@google.com> Committed: Wed May 25 14:16:54 2016 -0700 ---------------------------------------------------------------------- sdks/java/core/pom.xml | 2 +- .../apache/beam/sdk/testing/NeedsRunner.java | 28 ++++++++++++++++++++ .../beam/sdk/testing/RunnableOnService.java | 2 +- .../java/org/apache/beam/sdk/PipelineTest.java | 2 ++ .../apache/beam/sdk/coders/AvroCoderTest.java | 3 +++ .../beam/sdk/coders/CoderRegistryTest.java | 4 +++ .../beam/sdk/io/AvroIOGeneratedClassTest.java | 9 +++++++ .../java/org/apache/beam/sdk/io/AvroIOTest.java | 7 ++++- .../org/apache/beam/sdk/io/BigQueryIOTest.java | 11 +++++--- .../beam/sdk/io/CompressedSourceTest.java | 15 +++++++++++ .../apache/beam/sdk/io/CountingInputTest.java | 2 ++ .../apache/beam/sdk/io/CountingSourceTest.java | 3 +++ .../apache/beam/sdk/io/FileBasedSourceTest.java | 5 +++- .../beam/sdk/io/PubsubUnboundedSinkTest.java | 5 ++++ .../java/org/apache/beam/sdk/io/TextIOTest.java | 15 +++++++++++ .../java/org/apache/beam/sdk/io/WriteTest.java | 6 +++++ .../org/apache/beam/sdk/io/XmlSourceTest.java | 10 ++++--- .../beam/sdk/runners/TransformTreeTest.java | 3 +++ .../transforms/ApproximateQuantilesTest.java | 7 ++++- .../sdk/transforms/ApproximateUniqueTest.java | 6 +++++ .../apache/beam/sdk/transforms/CombineTest.java | 4 +-- .../apache/beam/sdk/transforms/DoFnTest.java | 7 ++++- .../sdk/transforms/DoFnWithContextTest.java | 7 ++++- .../apache/beam/sdk/transforms/FilterTest.java | 4 +++ .../sdk/transforms/FlatMapElementsTest.java | 5 ++++ .../apache/beam/sdk/transforms/FlattenTest.java | 4 +++ .../beam/sdk/transforms/GroupByKeyTest.java | 5 +++- .../IntraBundleParallelizationTest.java | 6 ++++- .../beam/sdk/transforms/MapElementsTest.java | 7 ++++- .../apache/beam/sdk/transforms/ParDoTest.java | 21 +++++++++++++-- .../beam/sdk/transforms/PartitionTest.java | 5 +++- .../apache/beam/sdk/transforms/SampleTest.java | 3 ++- .../org/apache/beam/sdk/transforms/TopTest.java | 5 ++++ .../apache/beam/sdk/transforms/ViewTest.java | 4 +++ .../beam/sdk/transforms/WithKeysTest.java | 5 ++++ .../beam/sdk/transforms/WithTimestampsTest.java | 3 +++ .../sdk/transforms/join/CoGroupByKeyTest.java | 2 ++ .../sdk/transforms/windowing/WindowingTest.java | 3 +++ .../org/apache/beam/sdk/values/PDoneTest.java | 2 ++ 39 files changed, 225 insertions(+), 22 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/bde2a856/sdks/java/core/src/test/java/org/apache/beam/sdk/io/BigQueryIOTest.java ----------------------------------------------------------------------