Repository: incubator-beam Updated Branches: refs/heads/master fc803f60e -> 7d767056a
Closes #536 Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/7d767056 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/7d767056 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/7d767056 Branch: refs/heads/master Commit: 7d767056a90e769eff68d4347e1b3a7bc43f415c Parents: fc803f6 02133b6 Author: Dan Halperin <[email protected]> Authored: Mon Jun 27 12:38:02 2016 -0700 Committer: Dan Halperin <[email protected]> Committed: Mon Jun 27 12:38:02 2016 -0700 ---------------------------------------------------------------------- .../beam/examples/complete/AutoComplete.java | 4 +- .../complete/game/injector/InjectorUtils.java | 6 +-- .../injector/RetryHttpInitializerWrapper.java | 5 +- .../beam/sdk/util/BatchTimerInternals.java | 7 +-- .../apache/beam/sdk/util/DoFnRunnerBase.java | 15 +++--- .../apache/beam/sdk/util/PaneInfoTracker.java | 11 +++-- .../beam/sdk/util/ReduceFnContextFactory.java | 6 +-- .../apache/beam/sdk/util/ReduceFnRunner.java | 26 +++++----- .../org/apache/beam/sdk/util/TriggerRunner.java | 5 +- .../org/apache/beam/sdk/util/WatermarkHold.java | 19 ++++---- .../beam/sdk/util/ReduceFnRunnerTest.java | 18 +++---- .../apache/beam/sdk/util/ReduceFnTester.java | 19 ++++---- .../beam/runners/direct/WatermarkManager.java | 5 +- .../FlinkPipelineExecutionEnvironment.java | 6 +-- .../FlinkStreamingTranslationContext.java | 8 +-- .../functions/FlinkProcessContext.java | 25 +++++----- .../translation/types/CoderTypeInformation.java | 6 +-- .../utils/SerializedPipelineOptions.java | 8 +-- .../streaming/FlinkAbstractParDoWrapper.java | 10 ++-- .../FlinkGroupAlsoByWindowWrapper.java | 23 ++++----- .../streaming/FlinkParDoBoundMultiWrapper.java | 8 +-- .../streaming/io/UnboundedFlinkSink.java | 2 +- .../streaming/io/UnboundedFlinkSource.java | 7 ++- .../streaming/state/FlinkStateInternals.java | 7 +-- .../dataflow/DataflowPipelineTranslator.java | 15 +++--- .../beam/runners/dataflow/DataflowRunner.java | 19 ++++---- .../runners/dataflow/internal/IsmFormat.java | 8 +-- .../options/DataflowWorkerLoggingOptions.java | 14 +++--- .../dataflow/util/DataflowPathValidator.java | 14 +++--- .../beam/runners/dataflow/util/GcsStager.java | 5 +- .../beam/runners/spark/io/CreateStream.java | 7 +-- .../apache/beam/runners/spark/io/KafkaIO.java | 23 ++++----- .../beam/runners/spark/io/hadoop/HadoopIO.java | 38 +++++++-------- .../main/java/org/apache/beam/sdk/Pipeline.java | 7 +-- .../java/org/apache/beam/sdk/coders/Coder.java | 6 +-- .../apache/beam/sdk/coders/CoderRegistry.java | 5 +- .../apache/beam/sdk/coders/CollectionCoder.java | 7 ++- .../apache/beam/sdk/coders/IterableCoder.java | 7 ++- .../beam/sdk/coders/IterableLikeCoder.java | 10 ++-- .../org/apache/beam/sdk/coders/KvCoder.java | 7 ++- .../org/apache/beam/sdk/coders/ListCoder.java | 7 ++- .../org/apache/beam/sdk/coders/MapCoder.java | 6 +-- .../apache/beam/sdk/coders/NullableCoder.java | 6 +-- .../org/apache/beam/sdk/coders/SetCoder.java | 7 ++- .../java/org/apache/beam/sdk/io/AvroIO.java | 6 +-- .../java/org/apache/beam/sdk/io/AvroSource.java | 12 ++--- .../apache/beam/sdk/io/CompressedSource.java | 10 ++-- .../org/apache/beam/sdk/io/DatastoreIO.java | 7 ++- .../org/apache/beam/sdk/io/FileBasedSink.java | 13 +++-- .../apache/beam/sdk/io/OffsetBasedSource.java | 12 ++--- .../java/org/apache/beam/sdk/io/TextIO.java | 6 +-- .../java/org/apache/beam/sdk/io/XmlSink.java | 10 ++-- .../java/org/apache/beam/sdk/io/XmlSource.java | 11 +++-- .../sdk/options/PipelineOptionsFactory.java | 28 +++++------ .../sdk/options/PipelineOptionsValidator.java | 18 ++++--- .../sdk/options/ProxyInvocationHandler.java | 9 ++-- .../apache/beam/sdk/runners/PipelineRunner.java | 6 +-- .../beam/sdk/runners/TransformHierarchy.java | 10 ++-- .../beam/sdk/runners/TransformTreeNode.java | 13 ++--- .../sdk/transforms/ApproximateQuantiles.java | 9 ++-- .../org/apache/beam/sdk/transforms/Combine.java | 8 +-- .../org/apache/beam/sdk/transforms/Create.java | 5 +- .../transforms/IntraBundleParallelization.java | 9 ++-- .../org/apache/beam/sdk/transforms/Sample.java | 6 +-- .../org/apache/beam/sdk/transforms/Top.java | 7 ++- .../sdk/transforms/display/DisplayData.java | 4 +- .../beam/sdk/transforms/join/CoGbkResult.java | 6 +-- .../beam/sdk/transforms/windowing/AfterAll.java | 6 +-- .../sdk/transforms/windowing/AfterFirst.java | 9 ++-- .../beam/sdk/transforms/windowing/PaneInfo.java | 11 +++-- ...AttemptAndTimeBoundedExponentialBackOff.java | 11 +++-- .../util/AttemptBoundedExponentialBackOff.java | 9 ++-- .../beam/sdk/util/BigQueryTableInserter.java | 5 +- .../org/apache/beam/sdk/util/Credentials.java | 5 +- .../apache/beam/sdk/util/ExecutableTrigger.java | 11 +++-- .../java/org/apache/beam/sdk/util/GcsUtil.java | 10 ++-- .../apache/beam/sdk/util/InstanceBuilder.java | 21 ++++---- .../util/IntervalBoundedExponentialBackOff.java | 10 ++-- .../beam/sdk/util/MergingActiveWindowSet.java | 35 +++++++------- .../apache/beam/sdk/util/SerializableUtils.java | 13 +++-- .../org/apache/beam/sdk/util/StringUtils.java | 12 +++-- .../apache/beam/sdk/util/TimerInternals.java | 5 +- .../apache/beam/sdk/util/ValueWithRecordId.java | 6 +-- .../org/apache/beam/sdk/util/WindowedValue.java | 5 +- .../beam/sdk/util/common/ReflectHelpers.java | 9 ++-- .../org/apache/beam/sdk/util/gcsfs/GcsPath.java | 51 ++++++++++---------- .../beam/sdk/util/state/StateMerging.java | 6 +-- .../apache/beam/sdk/transforms/CombineTest.java | 17 ++++--- .../apache/beam/sdk/transforms/ParDoTest.java | 7 ++- .../apache/beam/sdk/transforms/SampleTest.java | 6 +-- .../apache/beam/sdk/transforms/ViewTest.java | 10 ++-- .../org/apache/beam/sdk/util/TriggerTester.java | 3 +- .../beam/sdk/extensions/joinlibrary/Join.java | 19 ++++---- .../apache/beam/sdk/io/hdfs/HDFSFileSource.java | 23 ++++----- 94 files changed, 525 insertions(+), 509 deletions(-) ----------------------------------------------------------------------
