beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From da...@apache.org
Subject [5/5] incubator-beam git commit: This closes #146
Date Fri, 08 Apr 2016 21:02:10 GMT
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 <davor@google.com>
Authored: Fri Apr 8 13:55:07 2016 -0700
Committer: Davor Bonaci <davor@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(-)
----------------------------------------------------------------------



Mime
View raw message