This closes #4058: [BEAM-3081] NonNull by default in the rest of the core SDK and shared runner code
NonNull by default in runners/core NonNull by default in runners/core/metrics NonNull by default in runners/core/fn NonNull by default in runners/core/triggers NonNull by default in runners/core/construction/metrics NonNull by default in runners/core/construction NonNull by default in sdk/io/range NonNull by default in sdk/io/fs NonNull by default in sdk/values NonNull by default in sdk/io Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/e40e8825 Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/e40e8825 Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/e40e8825 Branch: refs/heads/tez-runner Commit: e40e88252ddc2b759926b8a29a00451475d759f6 Parents: b203af7 87b07d8 Author: Kenneth Knowles <k...@google.com> Authored: Thu Nov 9 17:11:12 2017 -0800 Committer: Kenneth Knowles <k...@google.com> Committed: Thu Nov 9 17:11:12 2017 -0800 ---------------------------------------------------------------------- .../apex/translation/utils/NoOpStepContext.java | 4 ++-- .../apex/translation/utils/ValuesSource.java | 4 +++- runners/core-construction-java/pom.xml | 5 ++++ .../construction/RunnerPCollectionView.java | 4 ++-- .../core/construction/SplittableParDo.java | 8 +++++-- .../UnboundedReadFromBoundedSource.java | 7 ++---- .../construction/WindowIntoTranslation.java | 3 ++- .../core/construction/metrics/package-info.java | 4 ++++ .../runners/core/construction/package-info.java | 4 ++++ runners/core-java/pom.xml | 5 ++++ .../runners/core/InMemoryStateInternals.java | 10 ++++---- ...eBoundedSplittableProcessElementInvoker.java | 8 +++---- .../beam/runners/core/PeekingReiterator.java | 3 ++- .../beam/runners/core/SimpleDoFnRunner.java | 2 +- .../core/SimplePushbackSideInputDoFnRunner.java | 4 +++- .../core/SplittableParDoViaKeyedWorkItems.java | 12 ++++++---- .../core/SplittableProcessElementInvoker.java | 6 ++--- .../beam/runners/core/fn/package-info.java | 4 ++++ .../core/metrics/MetricsContainerStepMap.java | 5 ++-- .../beam/runners/core/metrics/package-info.java | 4 ++++ .../apache/beam/runners/core/package-info.java | 4 ++++ .../TriggerStateMachineContextFactory.java | 2 +- .../runners/core/triggers/package-info.java | 4 ++++ .../functions/FlinkNoOpStepContext.java | 4 ++-- .../streaming/io/UnboundedSocketSource.java | 3 ++- .../state/FlinkBroadcastStateInternals.java | 2 ++ .../state/FlinkSplitStateInternals.java | 2 ++ .../gearpump/translators/io/ValuesSource.java | 2 +- .../spark/stateful/StateSpecFunctions.java | 9 +++----- .../spark/translation/SparkProcessContext.java | 4 ++-- .../java/org/apache/beam/sdk/io/AvroIO.java | 7 +++--- .../java/org/apache/beam/sdk/io/AvroSink.java | 6 ++++- .../java/org/apache/beam/sdk/io/AvroSource.java | 20 ++++++++++------ .../sdk/io/BoundedReadFromUnboundedSource.java | 11 +++++---- .../apache/beam/sdk/io/CompressedSource.java | 4 ++++ .../beam/sdk/io/ConstantAvroDestination.java | 2 ++ .../org/apache/beam/sdk/io/CountingSource.java | 9 ++++++-- .../beam/sdk/io/DefaultFilenamePolicy.java | 6 ++--- .../beam/sdk/io/DynamicFileDestinations.java | 3 +++ .../org/apache/beam/sdk/io/FileBasedSink.java | 24 ++++++++++++-------- .../org/apache/beam/sdk/io/FileBasedSource.java | 9 ++++++-- .../org/apache/beam/sdk/io/LocalResourceId.java | 4 +++- .../sdk/io/SerializableAvroCodecFactory.java | 5 ++-- .../java/org/apache/beam/sdk/io/TFRecordIO.java | 14 ++++++------ .../java/org/apache/beam/sdk/io/TextIO.java | 6 ++--- .../java/org/apache/beam/sdk/io/TextSink.java | 4 +++- .../java/org/apache/beam/sdk/io/TextSource.java | 7 +++--- .../org/apache/beam/sdk/io/UnboundedSource.java | 12 ++++++++++ .../java/org/apache/beam/sdk/io/WriteFiles.java | 18 +++++++-------- .../org/apache/beam/sdk/io/fs/package-info.java | 4 ++++ .../org/apache/beam/sdk/io/package-info.java | 4 ++++ .../apache/beam/sdk/io/range/package-info.java | 4 ++++ .../org/apache/beam/sdk/values/BeamRecord.java | 6 ++--- .../java/org/apache/beam/sdk/values/KV.java | 11 +++++---- .../org/apache/beam/sdk/values/PCollection.java | 12 ++++++---- .../beam/sdk/values/PCollectionViews.java | 10 +------- .../org/apache/beam/sdk/values/PValueBase.java | 22 +++++++++++------- .../beam/sdk/values/TimestampedValue.java | 9 ++++---- .../apache/beam/sdk/values/package-info.java | 4 ++++ 59 files changed, 259 insertions(+), 140 deletions(-) ----------------------------------------------------------------------