beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dhalp...@apache.org
Subject [3/3] incubator-beam git commit: Closes #1150
Date Fri, 21 Oct 2016 00:13:28 GMT
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 <dhalperi@google.com>
Authored: Thu Oct 20 17:13:19 2016 -0700
Committer: Dan Halperin <dhalperi@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(-)
----------------------------------------------------------------------



Mime
View raw message