You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by dh...@apache.org on 2016/10/21 00:13:28 UTC
[3/3] incubator-beam git commit: Closes #1150
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 <dh...@google.com>
Authored: Thu Oct 20 17:13:19 2016 -0700
Committer: Dan Halperin <dh...@google.com>
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(-)
----------------------------------------------------------------------