beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From k...@apache.org
Subject [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
Date Fri, 17 Nov 2017 20:30:54 GMT
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 <klk@google.com>
Authored: Thu Nov 9 17:11:12 2017 -0800
Committer: Kenneth Knowles <klk@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(-)
----------------------------------------------------------------------



Mime
View raw message