Return-Path: X-Original-To: apmail-beam-commits-archive@minotaur.apache.org Delivered-To: apmail-beam-commits-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 14E5F19C0A for ; Fri, 8 Apr 2016 21:02:10 +0000 (UTC) Received: (qmail 94160 invoked by uid 500); 8 Apr 2016 21:02:10 -0000 Delivered-To: apmail-beam-commits-archive@beam.apache.org Received: (qmail 94107 invoked by uid 500); 8 Apr 2016 21:02:09 -0000 Mailing-List: contact commits-help@beam.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@beam.incubator.apache.org Delivered-To: mailing list commits@beam.incubator.apache.org Received: (qmail 94098 invoked by uid 99); 8 Apr 2016 21:02:09 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd4-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 08 Apr 2016 21:02:09 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd4-us-west.apache.org (ASF Mail Server at spamd4-us-west.apache.org) with ESMTP id 77EF8C021C for ; Fri, 8 Apr 2016 21:02:09 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd4-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -3.221 X-Spam-Level: X-Spam-Status: No, score=-3.221 tagged_above=-999 required=6.31 tests=[KAM_ASCII_DIVIDERS=0.8, KAM_LAZY_DOMAIN_SECURITY=1, RCVD_IN_DNSWL_HI=-5, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, RP_MATCHES_RCVD=-0.001] autolearn=disabled Received: from mx2-lw-us.apache.org ([10.40.0.8]) by localhost (spamd4-us-west.apache.org [10.40.0.11]) (amavisd-new, port 10024) with ESMTP id kU7mXwXtyPuH for ; Fri, 8 Apr 2016 21:02:08 +0000 (UTC) Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx2-lw-us.apache.org (ASF Mail Server at mx2-lw-us.apache.org) with SMTP id B37835F47C for ; Fri, 8 Apr 2016 21:02:07 +0000 (UTC) Received: (qmail 94089 invoked by uid 99); 8 Apr 2016 21:02:07 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 08 Apr 2016 21:02:07 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id C6868E0901; Fri, 8 Apr 2016 21:02:06 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: davor@apache.org To: commits@beam.incubator.apache.org Date: Fri, 08 Apr 2016 21:02:10 -0000 Message-Id: In-Reply-To: References: X-Mailer: ASF-Git Admin Mailer Subject: [5/5] incubator-beam git commit: This closes #146 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 Authored: Fri Apr 8 13:55:07 2016 -0700 Committer: Davor Bonaci 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(-) ----------------------------------------------------------------------