Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id 905AE200BD5 for ; Thu, 8 Dec 2016 18:47:06 +0100 (CET) Received: by cust-asf.ponee.io (Postfix) id 8EF56160B0A; Thu, 8 Dec 2016 17:47:06 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id B32A8160B1F for ; Thu, 8 Dec 2016 18:47:05 +0100 (CET) Received: (qmail 36542 invoked by uid 500); 8 Dec 2016 17:47:05 -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 36533 invoked by uid 99); 8 Dec 2016 17:47:04 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd1-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 08 Dec 2016 17:47:04 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd1-us-west.apache.org (ASF Mail Server at spamd1-us-west.apache.org) with ESMTP id 790C8C8610 for ; Thu, 8 Dec 2016 17:47:04 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd1-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -5.725 X-Spam-Level: X-Spam-Status: No, score=-5.725 tagged_above=-999 required=6.31 tests=[FUZZY_VPILL=0.494, 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=-2.999] autolearn=disabled Received: from mx1-lw-eu.apache.org ([10.40.0.8]) by localhost (spamd1-us-west.apache.org [10.40.0.7]) (amavisd-new, port 10024) with ESMTP id EadwoCDRezyf for ; Thu, 8 Dec 2016 17:47:03 +0000 (UTC) Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx1-lw-eu.apache.org (ASF Mail Server at mx1-lw-eu.apache.org) with SMTP id B51915FC17 for ; Thu, 8 Dec 2016 17:47:02 +0000 (UTC) Received: (qmail 35719 invoked by uid 99); 8 Dec 2016 17:47:01 -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; Thu, 08 Dec 2016 17:47:01 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id C2138E36DC; Thu, 8 Dec 2016 17:47:00 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: kenn@apache.org To: commits@beam.incubator.apache.org Date: Thu, 08 Dec 2016 17:47:00 -0000 Message-Id: <0644391ce58d4f0aba3328bb43509b09@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [1/3] incubator-beam git commit: This closes #1538 archived-at: Thu, 08 Dec 2016 17:47:06 -0000 Repository: incubator-beam Updated Branches: refs/heads/master 04a41ee54 -> 692905705 This closes #1538 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/69290570 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/69290570 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/69290570 Branch: refs/heads/master Commit: 692905705fee3666bdbf85e67e5a037244d668b8 Parents: 04a41ee 4d607b5 Author: Kenneth Knowles Authored: Thu Dec 8 09:35:36 2016 -0800 Committer: Kenneth Knowles Committed: Thu Dec 8 09:35:36 2016 -0800 ---------------------------------------------------------------------- .../org/apache/beam/examples/WordCount.java | 2 +- .../beam/examples/complete/AutoComplete.java | 6 +-- .../apache/beam/examples/complete/TfIdf.java | 6 +-- .../examples/complete/TopWikipediaSessions.java | 6 +-- .../examples/complete/TrafficMaxLaneFlow.java | 4 +- .../beam/examples/complete/TrafficRoutes.java | 4 +- .../examples/cookbook/BigQueryTornadoes.java | 2 +- .../cookbook/CombinePerKeyExamples.java | 2 +- .../beam/examples/cookbook/FilterExamples.java | 2 +- .../examples/cookbook/MaxPerKeyExamples.java | 2 +- .../beam/examples/cookbook/TriggerExample.java | 4 +- .../examples/complete/AutoCompleteTest.java | 2 +- .../beam/examples/complete/game/GameStats.java | 2 +- .../examples/complete/game/LeaderBoard.java | 4 +- .../beam/examples/complete/game/UserScore.java | 2 +- .../complete/game/utils/WriteToBigQuery.java | 2 +- .../game/utils/WriteWindowedToBigQuery.java | 2 +- .../apache/beam/runners/apex/ApexRunner.java | 10 ++-- .../apache/beam/runners/core/AssignWindows.java | 2 +- .../core/GroupByKeyViaGroupByKeyOnly.java | 8 +-- .../beam/runners/core/SplittableParDo.java | 6 +-- .../core/UnboundedReadFromBoundedSource.java | 2 +- .../beam/runners/direct/DirectGroupByKey.java | 6 +-- .../runners/direct/ForwardingPTransform.java | 6 +-- .../direct/ParDoMultiOverrideFactory.java | 4 +- .../ParDoSingleViaMultiOverrideFactory.java | 2 +- .../direct/TestStreamEvaluatorFactory.java | 2 +- .../runners/direct/ViewEvaluatorFactory.java | 4 +- .../direct/WriteWithShardingFactory.java | 4 +- .../runners/direct/CommittedResultTest.java | 2 +- .../runners/direct/DirectGraphVisitorTest.java | 2 +- .../direct/ForwardingPTransformTest.java | 4 +- .../direct/KeyedPValueTrackingVisitorTest.java | 4 +- .../beam/runners/flink/examples/TFIDF.java | 6 +-- .../beam/runners/flink/examples/WordCount.java | 2 +- .../flink/examples/streaming/AutoComplete.java | 6 +-- .../apache/beam/runners/flink/FlinkRunner.java | 14 +++--- .../beam/runners/dataflow/DataflowRunner.java | 51 ++++++++++---------- .../dataflow/internal/AssignWindows.java | 2 +- .../DataflowUnboundedReadFromBoundedSource.java | 2 +- .../DataflowPipelineTranslatorTest.java | 8 +-- .../runners/dataflow/DataflowRunnerTest.java | 2 +- .../transforms/DataflowGroupByKeyTest.java | 2 +- .../dataflow/transforms/DataflowViewTest.java | 2 +- .../beam/runners/spark/examples/WordCount.java | 2 +- .../apache/beam/runners/spark/io/ConsoleIO.java | 2 +- .../beam/runners/spark/io/CreateStream.java | 2 +- .../beam/runners/spark/io/hadoop/HadoopIO.java | 4 +- .../translation/StorageLevelPTransform.java | 2 +- .../util/SinglePrimitiveOutputPTransform.java | 2 +- .../java/org/apache/beam/sdk/io/AvroIO.java | 4 +- .../sdk/io/BoundedReadFromUnboundedSource.java | 2 +- .../org/apache/beam/sdk/io/CountingInput.java | 4 +- .../java/org/apache/beam/sdk/io/PubsubIO.java | 4 +- .../apache/beam/sdk/io/PubsubUnboundedSink.java | 2 +- .../beam/sdk/io/PubsubUnboundedSource.java | 2 +- .../main/java/org/apache/beam/sdk/io/Read.java | 4 +- .../java/org/apache/beam/sdk/io/TextIO.java | 4 +- .../main/java/org/apache/beam/sdk/io/Write.java | 2 +- .../apache/beam/sdk/runners/PipelineRunner.java | 2 +- .../apache/beam/sdk/testing/GatherAllPanes.java | 2 +- .../org/apache/beam/sdk/testing/PAssert.java | 12 ++--- .../org/apache/beam/sdk/testing/TestStream.java | 2 +- .../beam/sdk/transforms/ApproximateUnique.java | 4 +- .../org/apache/beam/sdk/transforms/Combine.java | 10 ++-- .../org/apache/beam/sdk/transforms/Count.java | 2 +- .../org/apache/beam/sdk/transforms/Create.java | 4 +- .../apache/beam/sdk/transforms/Distinct.java | 4 +- .../org/apache/beam/sdk/transforms/Filter.java | 2 +- .../beam/sdk/transforms/FlatMapElements.java | 2 +- .../org/apache/beam/sdk/transforms/Flatten.java | 4 +- .../apache/beam/sdk/transforms/GroupByKey.java | 2 +- .../org/apache/beam/sdk/transforms/Keys.java | 2 +- .../org/apache/beam/sdk/transforms/KvSwap.java | 2 +- .../org/apache/beam/sdk/transforms/Latest.java | 4 +- .../apache/beam/sdk/transforms/MapElements.java | 2 +- .../apache/beam/sdk/transforms/PTransform.java | 4 +- .../org/apache/beam/sdk/transforms/ParDo.java | 4 +- .../apache/beam/sdk/transforms/Partition.java | 2 +- .../org/apache/beam/sdk/transforms/Regex.java | 14 +++--- .../org/apache/beam/sdk/transforms/Sample.java | 2 +- .../org/apache/beam/sdk/transforms/Values.java | 2 +- .../org/apache/beam/sdk/transforms/View.java | 12 ++--- .../apache/beam/sdk/transforms/WithKeys.java | 2 +- .../beam/sdk/transforms/WithTimestamps.java | 2 +- .../beam/sdk/transforms/join/CoGroupByKey.java | 2 +- .../beam/sdk/transforms/windowing/Window.java | 4 +- .../org/apache/beam/sdk/util/Reshuffle.java | 2 +- .../java/org/apache/beam/sdk/PipelineTest.java | 6 +-- .../beam/sdk/coders/CoderRegistryTest.java | 4 +- .../java/org/apache/beam/sdk/io/WriteTest.java | 2 +- .../sdk/runners/TransformHierarchyTest.java | 4 +- .../beam/sdk/runners/TransformTreeTest.java | 4 +- .../sdk/transforms/FlatMapElementsTest.java | 2 +- .../beam/sdk/transforms/GroupByKeyTest.java | 2 +- .../beam/sdk/transforms/MapElementsTest.java | 2 +- .../beam/sdk/transforms/PTransformTest.java | 2 +- .../apache/beam/sdk/transforms/ParDoTest.java | 4 +- .../apache/beam/sdk/transforms/ViewTest.java | 2 +- .../display/DisplayDataEvaluatorTest.java | 2 +- .../display/DisplayDataMatchersTest.java | 6 +-- .../sdk/transforms/display/DisplayDataTest.java | 2 +- .../sdk/transforms/windowing/WindowingTest.java | 2 +- .../apache/beam/sdk/util/StringUtilsTest.java | 6 +-- .../org/apache/beam/sdk/values/PDoneTest.java | 4 +- .../beam/sdk/extensions/sorter/SortValues.java | 2 +- .../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 8 +-- .../beam/sdk/io/gcp/bigtable/BigtableIO.java | 4 +- .../beam/sdk/io/gcp/datastore/DatastoreV1.java | 4 +- .../org/apache/beam/sdk/io/jdbc/JdbcIO.java | 4 +- .../java/org/apache/beam/sdk/io/jms/JmsIO.java | 4 +- .../org/apache/beam/sdk/io/kafka/KafkaIO.java | 10 ++-- .../beam/sdk/io/mongodb/MongoDbGridFSIO.java | 4 +- .../apache/beam/sdk/io/mongodb/MongoDbIO.java | 4 +- 114 files changed, 238 insertions(+), 237 deletions(-) ----------------------------------------------------------------------