Closes #1150
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/465c7d1f Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/465c7d1f Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/465c7d1f Branch: refs/heads/master Commit: 465c7d1f1e4f77e3de218365005f06e8e4ec6167 Parents: 2efc278 c4cfb21 Author: Dan Halperin <[email protected]> Authored: Thu Oct 20 17:13:19 2016 -0700 Committer: Dan Halperin <[email protected]> Committed: Thu Oct 20 17:13:19 2016 -0700 ---------------------------------------------------------------------- .../org/apache/beam/examples/WordCount.java | 2 +- .../common/ExampleBigQueryTableOptions.java | 2 +- ...xamplePubsubTopicAndSubscriptionOptions.java | 2 +- .../common/ExamplePubsubTopicOptions.java | 2 +- .../beam/examples/cookbook/DeDupExample.java | 2 +- .../apache/beam/runners/core/DoFnRunner.java | 6 ++--- .../apache/beam/runners/core/DoFnRunners.java | 2 +- .../runners/core/ElementByteSizeObservable.java | 5 ++-- .../runners/core/ReduceFnContextFactory.java | 2 +- .../runners/core/triggers/FinishedTriggers.java | 8 +++--- .../core/triggers/TriggerStateMachine.java | 4 +-- .../beam/runners/direct/WatermarkManager.java | 2 +- .../runners/direct/WatermarkManagerTest.java | 2 +- .../dataflow/DataflowPipelineTranslator.java | 28 ++++++++++---------- .../options/DataflowPipelineDebugOptions.java | 4 +-- .../options/DataflowPipelineOptions.java | 2 +- .../DataflowPipelineWorkerPoolOptions.java | 8 +++--- .../options/DataflowProfilingOptions.java | 2 +- .../options/DataflowWorkerLoggingOptions.java | 4 +-- .../beam/runners/dataflow/util/Stager.java | 2 +- .../runners/spark/SparkPipelineOptions.java | 4 +-- .../src/main/resources/beam/checkstyle.xml | 7 +++++ .../main/java/org/apache/beam/sdk/Pipeline.java | 12 ++++----- .../org/apache/beam/sdk/PipelineResult.java | 4 +-- .../beam/sdk/annotations/Experimental.java | 4 +-- .../sdk/coders/CannotProvideCoderException.java | 2 +- .../java/org/apache/beam/sdk/coders/Coder.java | 26 +++++++++--------- .../apache/beam/sdk/coders/CoderFactory.java | 4 +-- .../apache/beam/sdk/coders/CoderProvider.java | 2 +- .../apache/beam/sdk/coders/DelegateCoder.java | 2 +- .../apache/beam/sdk/io/CompressedSource.java | 2 +- .../org/apache/beam/sdk/io/FileBasedSink.java | 12 ++++----- .../java/org/apache/beam/sdk/io/TextIO.java | 4 +-- .../org/apache/beam/sdk/options/GcpOptions.java | 8 +++--- .../org/apache/beam/sdk/options/GcsOptions.java | 4 +-- .../beam/sdk/options/GoogleApiDebugOptions.java | 2 +- .../beam/sdk/options/PipelineOptions.java | 4 +-- .../apache/beam/sdk/options/ValueProvider.java | 8 +++--- .../sdk/runners/PipelineRunnerRegistrar.java | 2 +- .../org/apache/beam/sdk/testing/PAssert.java | 2 +- .../org/apache/beam/sdk/transforms/Combine.java | 8 +++--- .../beam/sdk/transforms/CombineFnBase.java | 17 ++++++------ .../org/apache/beam/sdk/transforms/OldDoFn.java | 2 +- .../apache/beam/sdk/transforms/Partition.java | 2 +- .../sdk/transforms/SerializableFunction.java | 2 +- .../sdk/transforms/reflect/DoFnSignature.java | 2 +- .../sdk/transforms/reflect/DoFnSignatures.java | 2 +- .../beam/sdk/transforms/windowing/PaneInfo.java | 2 +- .../beam/sdk/transforms/windowing/Trigger.java | 4 +-- .../beam/sdk/transforms/windowing/WindowFn.java | 2 +- ...AttemptAndTimeBoundedExponentialBackOff.java | 2 +- .../apache/beam/sdk/util/CredentialFactory.java | 2 +- .../apache/beam/sdk/util/FinishedTriggers.java | 8 +++--- .../apache/beam/sdk/util/IOChannelFactory.java | 2 +- .../org/apache/beam/sdk/util/PathValidator.java | 6 ++--- .../beam/sdk/util/PerKeyCombineFnRunner.java | 26 +++++++++--------- .../apache/beam/sdk/util/TimerInternals.java | 4 +-- .../java/org/apache/beam/sdk/util/Timers.java | 10 +++---- .../apache/beam/sdk/util/common/Reiterable.java | 2 +- .../apache/beam/sdk/util/common/Reiterator.java | 2 +- .../beam/sdk/util/state/StateContext.java | 6 ++--- .../apache/beam/sdk/values/PCollectionView.java | 8 +++--- .../java/org/apache/beam/sdk/values/PInput.java | 6 ++--- .../org/apache/beam/sdk/values/POutput.java | 8 +++--- .../java/org/apache/beam/sdk/values/PValue.java | 4 +-- .../apache/beam/sdk/coders/AvroCoderTest.java | 4 +-- .../sdk/options/PipelineOptionsFactoryTest.java | 2 +- .../apache/beam/sdk/util/ApiSurfaceTest.java | 2 +- 68 files changed, 179 insertions(+), 174 deletions(-) ----------------------------------------------------------------------
