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/11 23:39:28 UTC
[3/3] incubator-beam git commit: Closes #1060
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 <dh...@google.com>
Authored: Tue Oct 11 16:39:15 2016 -0700
Committer: Dan Halperin <dh...@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(-)
----------------------------------------------------------------------