This closes #146
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/529bcdf5 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/529bcdf5 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/529bcdf5 Branch: refs/heads/master Commit: 529bcdf5688139ae76bcbcaa1c0dbbf44c3008bc Parents: 5f24cef d73ceab Author: Davor Bonaci <da...@google.com> Authored: Fri Apr 8 13:55:07 2016 -0700 Committer: Davor Bonaci <da...@google.com> Committed: Fri Apr 8 13:55:07 2016 -0700 ---------------------------------------------------------------------- .../contrib/joinlibrary/InnerJoinTest.java | 10 +- .../contrib/joinlibrary/OuterLeftJoinTest.java | 10 +- .../contrib/joinlibrary/OuterRightJoinTest.java | 10 +- examples/java/pom.xml | 2 +- .../dataflow/examples/DebuggingWordCount.java | 12 +- .../cloud/dataflow/examples/WordCountTest.java | 4 +- .../examples/complete/AutoCompleteTest.java | 8 +- .../dataflow/examples/complete/TfIdfTest.java | 4 +- .../complete/TopWikipediaSessionsTest.java | 4 +- .../examples/cookbook/DeDupExampleTest.java | 6 +- .../examples/cookbook/JoinExamplesTest.java | 4 +- .../examples/cookbook/TriggerExampleTest.java | 4 +- .../examples/complete/game/GameStatsTest.java | 4 +- .../complete/game/HourlyTeamScoreTest.java | 4 +- .../examples/complete/game/UserScoreTest.java | 8 +- .../beam/runners/flink/FlinkTestPipeline.java | 6 +- .../streaming/StreamingTransformTranslator.java | 4 +- .../apache/beam/runners/spark/DeDupTest.java | 4 +- .../beam/runners/spark/SimpleWordCountTest.java | 4 +- .../apache/beam/runners/spark/TfIdfTest.java | 4 +- .../spark/translation/DoFnOutputTest.java | 4 +- .../translation/MultiOutputWordCountTest.java | 4 +- .../spark/translation/SerializationTest.java | 4 +- .../translation/WindowedWordCountTest.java | 8 +- .../streaming/FlattenStreamingTest.java | 8 +- .../streaming/KafkaStreamingTest.java | 8 +- .../streaming/SimpleStreamingWordCountTest.java | 8 +- .../utils/DataflowAssertStreaming.java | 42 - .../streaming/utils/PAssertStreaming.java | 42 + .../dataflow/sdk/testing/DataflowAssert.java | 826 ------------------- .../cloud/dataflow/sdk/testing/PAssert.java | 825 ++++++++++++++++++ .../sdk/testing/SerializableMatcher.java | 2 +- .../dataflow/sdk/testing/SourceTestUtils.java | 2 +- .../sdk/testing/TestDataflowPipelineRunner.java | 8 +- .../dataflow/sdk/testing/TestPipeline.java | 6 +- .../google/cloud/dataflow/sdk/PipelineTest.java | 10 +- .../dataflow/sdk/coders/AvroCoderTest.java | 4 +- .../sdk/coders/SerializableCoderTest.java | 4 +- .../cloud/dataflow/sdk/io/AvroIOTest.java | 6 +- .../io/BoundedReadFromUnboundedSourceTest.java | 4 +- .../dataflow/sdk/io/CompressedSourceTest.java | 10 +- .../dataflow/sdk/io/CountingInputTest.java | 12 +- .../dataflow/sdk/io/CountingSourceTest.java | 14 +- .../dataflow/sdk/io/FileBasedSourceTest.java | 6 +- .../cloud/dataflow/sdk/io/TextIOTest.java | 8 +- .../cloud/dataflow/sdk/io/XmlSourceTest.java | 8 +- .../sdk/io/bigtable/BigtableIOTest.java | 8 +- .../sdk/runners/dataflow/CustomSourcesTest.java | 6 +- .../runners/inprocess/InProcessCreateTest.java | 8 +- .../inprocess/InProcessPipelineRunnerTest.java | 4 +- .../sdk/testing/DataflowAssertTest.java | 327 -------- .../cloud/dataflow/sdk/testing/PAssertTest.java | 331 ++++++++ .../testing/TestDataflowPipelineRunnerTest.java | 24 +- .../transforms/ApproximateQuantilesTest.java | 10 +- .../sdk/transforms/ApproximateUniqueTest.java | 12 +- .../dataflow/sdk/transforms/CombineFnsTest.java | 12 +- .../dataflow/sdk/transforms/CombineTest.java | 66 +- .../dataflow/sdk/transforms/CountTest.java | 10 +- .../dataflow/sdk/transforms/CreateTest.java | 18 +- .../dataflow/sdk/transforms/FilterTest.java | 18 +- .../sdk/transforms/FlatMapElementsTest.java | 4 +- .../dataflow/sdk/transforms/FlattenTest.java | 22 +- .../dataflow/sdk/transforms/GroupByKeyTest.java | 8 +- .../cloud/dataflow/sdk/transforms/KeysTest.java | 6 +- .../dataflow/sdk/transforms/KvSwapTest.java | 6 +- .../sdk/transforms/MapElementsTest.java | 6 +- .../dataflow/sdk/transforms/ParDoTest.java | 66 +- .../dataflow/sdk/transforms/PartitionTest.java | 14 +- .../sdk/transforms/RemoveDuplicatesTest.java | 8 +- .../dataflow/sdk/transforms/SampleTest.java | 14 +- .../cloud/dataflow/sdk/transforms/TopTest.java | 32 +- .../dataflow/sdk/transforms/ValuesTest.java | 6 +- .../cloud/dataflow/sdk/transforms/ViewTest.java | 72 +- .../dataflow/sdk/transforms/WithKeysTest.java | 8 +- .../sdk/transforms/WithTimestampsTest.java | 10 +- .../sdk/transforms/join/CoGroupByKeyTest.java | 10 +- .../sdk/transforms/windowing/WindowingTest.java | 14 +- .../cloud/dataflow/sdk/util/ReshuffleTest.java | 14 +- .../sdk/values/PCollectionTupleTest.java | 8 +- .../sdk/transforms/CombineJava8Test.java | 10 +- .../sdk/transforms/FilterJava8Test.java | 10 +- .../transforms/FlatMapElementsJava8Test.java | 6 +- .../sdk/transforms/MapElementsJava8Test.java | 6 +- .../sdk/transforms/PartitionJava8Test.java | 8 +- .../transforms/RemoveDuplicatesJava8Test.java | 4 +- .../sdk/transforms/WithKeysJava8Test.java | 4 +- .../sdk/transforms/WithTimestampsJava8Test.java | 6 +- .../main/resources/archetype-resources/pom.xml | 2 +- .../src/main/java/DebuggingWordCount.java | 12 +- .../src/test/java/WordCountTest.java | 4 +- 90 files changed, 1628 insertions(+), 1625 deletions(-) ----------------------------------------------------------------------
