Repository: incubator-beam Updated Branches: refs/heads/master 638cc2071 -> d627266d8
Closes #341 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/d627266d Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/d627266d Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/d627266d Branch: refs/heads/master Commit: d627266d8d39ff0ec94dc9f3f84893c1026abde7 Parents: 638cc20 99f1925 Author: Dan Halperin <dhalp...@google.com> Authored: Mon May 16 23:25:14 2016 -0700 Committer: Dan Halperin <dhalp...@google.com> Committed: Mon May 16 23:25:14 2016 -0700 ---------------------------------------------------------------------- .../examples/complete/game/injector/Injector.java | 10 +++++----- .../runners/direct/InProcessEvaluationContext.java | 6 +++--- .../beam/runners/direct/TransformExecutorTest.java | 6 +++--- .../runners/dataflow/DataflowPipelineRunner.java | 4 ++-- .../dataflow/testing/TestDataflowPipelineRunner.java | 4 ++-- .../runners/dataflow/util/DataflowTransport.java | 4 ++-- .../beam/runners/spark/SparkPipelineRunner.java | 10 +++++----- .../runners/spark/SparkStreamingPipelineOptions.java | 4 ++-- .../spark/translation/SparkContextFactory.java | 4 ++-- .../spark/translation/SparkProcessContext.java | 8 ++++---- .../streaming/StreamingWindowPipelineDetector.java | 4 ++-- .../src/main/resources/beam/checkstyle.xml | 10 ++++++++++ .../org/apache/beam/sdk/coders/CoderFactories.java | 10 +++++----- .../main/java/org/apache/beam/sdk/io/BigQueryIO.java | 6 +++--- .../java/org/apache/beam/sdk/io/FileBasedSource.java | 3 +-- .../beam/sdk/runners/DirectPipelineRunner.java | 15 +++++++-------- .../org/apache/beam/sdk/transforms/Partition.java | 4 ++-- .../apache/beam/sdk/transforms/join/CoGbkResult.java | 8 ++++---- .../apache/beam/sdk/transforms/join/UnionCoder.java | 4 ++-- .../apache/beam/sdk/util/BigQueryTableInserter.java | 8 ++++---- .../org/apache/beam/sdk/util/InstanceBuilder.java | 6 +++--- .../java/org/apache/beam/sdk/util/StringUtils.java | 4 ++-- .../java/org/apache/beam/sdk/util/Transport.java | 4 ++-- .../org/apache/beam/sdk/values/PCollectionList.java | 4 ++-- .../sdk/transforms/display/DisplayDataMatchers.java | 4 ++-- .../apache/beam/sdk/values/PCollectionListTest.java | 4 ++-- .../java/org/apache/beam/sdk/io/kafka/KafkaIO.java | 8 ++++---- 27 files changed, 87 insertions(+), 79 deletions(-) ----------------------------------------------------------------------
