You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2017/11/17 20:30:54 UTC
[03/50] [abbrv] beam git commit: This closes #4058: [BEAM-3081]
NonNull by default in the rest of the core SDK and shared runner code
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 <kl...@google.com>
Authored: Thu Nov 9 17:11:12 2017 -0800
Committer: Kenneth Knowles <kl...@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(-)
----------------------------------------------------------------------