beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From k...@apache.org
Subject [1/3] incubator-beam git commit: This closes #1538
Date Thu, 08 Dec 2016 17:47:00 GMT
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 <klk@google.com>
Authored: Thu Dec 8 09:35:36 2016 -0800
Committer: Kenneth Knowles <klk@google.com>
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(-)
----------------------------------------------------------------------



Mime
View raw message