Closes #1060
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/135790bc Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/135790bc Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/135790bc Branch: refs/heads/master Commit: 135790bc97e84b79d4b6d3728b86961fa738a212 Parents: 7c2124b 9e30a98 Author: Dan Halperin <dhalp...@google.com> Authored: Tue Oct 11 16:39:15 2016 -0700 Committer: Dan Halperin <dhalp...@google.com> Committed: Tue Oct 11 16:39:15 2016 -0700 ---------------------------------------------------------------------- .../beam/examples/cookbook/TriggerExample.java | 28 ++++++++++---------- .../beam/examples/complete/game/GameStats.java | 8 +++--- .../examples/complete/game/HourlyTeamScore.java | 6 ++--- .../examples/complete/game/LeaderBoard.java | 10 +++---- .../beam/examples/complete/game/UserScore.java | 8 +++--- .../complete/game/injector/Injector.java | 10 +++---- .../apache/beam/runners/core/DoFnRunner.java | 2 +- .../runners/direct/DirectExecutionContext.java | 2 +- .../beam/runners/direct/DirectRunner.java | 13 +++++---- .../direct/ExecutorServiceParallelExecutor.java | 2 +- .../beam/runners/direct/TransformEvaluator.java | 2 +- .../beam/runners/direct/TransformResult.java | 4 +-- .../runners/direct/ViewEvaluatorFactory.java | 2 +- .../beam/runners/direct/WatermarkManager.java | 4 +-- .../beam/runners/flink/examples/TFIDF.java | 12 ++++----- .../beam/runners/flink/examples/WordCount.java | 4 +-- .../flink/examples/streaming/AutoComplete.java | 4 +-- .../runners/flink/FlinkPipelineOptions.java | 8 +++--- .../apache/beam/runners/flink/FlinkRunner.java | 1 - .../runners/flink/FlinkRunnerRegistrar.java | 4 +-- .../functions/FlinkMultiOutputDoFnFunction.java | 2 +- .../beam/runners/flink/FlinkTestPipeline.java | 6 ++--- .../beam/runners/dataflow/DataflowRunner.java | 9 ++++--- .../dataflow/internal/AssignWindows.java | 6 ++--- .../runners/dataflow/internal/IsmFormat.java | 8 +++--- .../options/DataflowPipelineDebugOptions.java | 3 +-- .../runners/dataflow/util/RandomAccessData.java | 8 +++--- .../apache/beam/runners/spark/SparkRunner.java | 2 +- .../beam/runners/spark/TestSparkRunner.java | 4 +-- .../runners/spark/coders/WritableCoder.java | 2 +- .../spark/io/hadoop/ShardNameTemplateAware.java | 2 +- .../translation/GroupCombineFunctions.java | 4 +-- .../spark/translation/TranslationUtils.java | 2 +- .../RecoverFromCheckpointStreamingTest.java | 4 +-- .../src/main/resources/beam/checkstyle.xml | 3 +++ .../java/org/apache/beam/sdk/io/AvroSource.java | 1 + .../org/apache/beam/sdk/io/BoundedSource.java | 19 ++++++++----- .../org/apache/beam/sdk/io/FileBasedSink.java | 1 + .../apache/beam/sdk/io/OffsetBasedSource.java | 2 ++ .../java/org/apache/beam/sdk/io/PubsubIO.java | 1 + .../main/java/org/apache/beam/sdk/io/Sink.java | 3 +++ .../java/org/apache/beam/sdk/io/TextIO.java | 11 ++++---- .../main/java/org/apache/beam/sdk/io/Write.java | 2 +- .../apache/beam/sdk/io/range/RangeTracker.java | 1 + .../beam/sdk/options/PipelineOptions.java | 8 +++--- .../sdk/options/ProxyInvocationHandler.java | 2 +- .../beam/sdk/testing/SerializableMatchers.java | 4 +-- .../beam/sdk/testing/SourceTestUtils.java | 3 ++- .../sdk/transforms/ApproximateQuantiles.java | 5 ++-- .../org/apache/beam/sdk/transforms/Combine.java | 6 ++--- .../apache/beam/sdk/transforms/CombineFns.java | 8 +++--- .../beam/sdk/transforms/CombineWithContext.java | 4 +-- .../apache/beam/sdk/transforms/GroupByKey.java | 4 +-- .../org/apache/beam/sdk/transforms/Latest.java | 12 ++++----- .../org/apache/beam/sdk/transforms/OldDoFn.java | 2 +- .../apache/beam/sdk/transforms/PTransform.java | 8 +++--- .../org/apache/beam/sdk/transforms/ParDo.java | 14 +++++----- .../beam/sdk/transforms/RemoveDuplicates.java | 5 ++-- .../org/apache/beam/sdk/transforms/ViewFn.java | 2 +- .../apache/beam/sdk/transforms/WithKeys.java | 2 +- .../sdk/transforms/display/DisplayData.java | 8 +++--- .../sdk/transforms/reflect/DoFnInvoker.java | 2 +- .../transforms/windowing/AfterWatermark.java | 4 +-- .../beam/sdk/transforms/windowing/Never.java | 3 +-- .../beam/sdk/transforms/windowing/PaneInfo.java | 4 +-- .../transforms/windowing/SlidingWindows.java | 3 +-- .../beam/sdk/transforms/windowing/Window.java | 18 ++++++------- .../beam/sdk/util/BaseExecutionContext.java | 4 +-- .../sdk/util/ExposedByteArrayOutputStream.java | 1 + .../apache/beam/sdk/util/GatherAllPanes.java | 10 +++---- .../beam/sdk/util/PerKeyCombineFnRunners.java | 4 +-- .../org/apache/beam/sdk/util/PubsubClient.java | 3 +++ .../apache/beam/sdk/util/PubsubTestClient.java | 2 +- .../apache/beam/sdk/util/TimerInternals.java | 2 +- .../java/org/apache/beam/sdk/values/PInput.java | 2 +- .../apache/beam/sdk/values/TypeDescriptors.java | 16 +++++------ .../beam/sdk/testing/SystemNanoTimeSleeper.java | 2 +- .../beam/sdk/transforms/DoFnTesterTest.java | 2 +- .../sdk/io/gcp/bigquery/BigQueryAvroUtils.java | 2 +- .../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 5 ++++ .../sdk/io/gcp/bigquery/BigQueryServices.java | 2 +- .../beam/sdk/io/gcp/datastore/DatastoreIO.java | 2 +- .../beam/sdk/io/gcp/datastore/DatastoreV1.java | 2 +- .../sdk/io/gcp/datastore/SplitQueryFnIT.java | 4 +-- .../beam/sdk/io/gcp/datastore/V1ReadIT.java | 2 +- .../beam/sdk/io/gcp/datastore/V1WriteIT.java | 2 +- .../apache/beam/sdk/io/hdfs/HDFSFileSource.java | 3 ++- .../apache/beam/sdk/io/hdfs/WritableCoder.java | 2 +- .../SimpleAuthAvroHDFSFileSource.java | 2 +- .../hdfs/simpleauth/SimpleAuthHDFSFileSink.java | 2 +- .../simpleauth/SimpleAuthHDFSFileSource.java | 2 +- .../java/org/apache/beam/sdk/io/jms/JmsIO.java | 8 +++--- .../org/apache/beam/sdk/io/kafka/KafkaIO.java | 16 +++++------ .../beam/sdk/io/kinesis/CustomOptional.java | 2 +- .../sdk/io/kinesis/GetKinesisRecordsResult.java | 2 +- .../sdk/io/kinesis/KinesisClientProvider.java | 2 +- .../apache/beam/sdk/io/kinesis/KinesisIO.java | 14 +++++----- .../beam/sdk/io/kinesis/KinesisReader.java | 10 +++---- .../sdk/io/kinesis/KinesisReaderCheckpoint.java | 4 +-- .../beam/sdk/io/kinesis/KinesisRecordCoder.java | 2 +- .../beam/sdk/io/kinesis/KinesisSource.java | 6 ++--- .../beam/sdk/io/kinesis/RecordFilter.java | 6 ++--- .../apache/beam/sdk/io/kinesis/RoundRobin.java | 2 +- .../beam/sdk/io/kinesis/ShardCheckpoint.java | 6 ++--- .../sdk/io/kinesis/ShardRecordsIterator.java | 4 +-- .../sdk/io/kinesis/SimplifiedKinesisClient.java | 8 +++--- .../beam/sdk/io/kinesis/StartingPoint.java | 2 +- .../beam/sdk/io/kinesis/KinesisTestOptions.java | 2 +- .../beam/sdk/io/kinesis/KinesisUploader.java | 2 +- .../beam/sdk/io/mongodb/MongoDbGridFSIO.java | 6 ++--- .../apache/beam/sdk/io/mongodb/MongoDbIO.java | 7 +++-- 111 files changed, 293 insertions(+), 269 deletions(-) ----------------------------------------------------------------------