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/10/28 16:18:39 UTC
[7/7] beam git commit: This closes #4049: [BEAM-3081] NonNull by
default for sdk/transforms and below
This closes #4049: [BEAM-3081] NonNull by default for sdk/transforms and below
NonNull by default in sdk/transforms/splittabledofn
NonNull by default in sdk/transforms/join
NonNull by default in sdk/transforms/display
NonNull by default in sdk/transforms/reflect
NonNull by default in sdk/transforms/windowing
NonNull by default in sdk/transforms
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/5fb30ec8
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/5fb30ec8
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/5fb30ec8
Branch: refs/heads/master
Commit: 5fb30ec8265c841cd8c4e6ae16b43be1f171eabb
Parents: e686286 82fc720
Author: Kenneth Knowles <kl...@google.com>
Authored: Sat Oct 28 08:43:06 2017 -0700
Committer: Kenneth Knowles <kl...@google.com>
Committed: Sat Oct 28 08:43:06 2017 -0700
----------------------------------------------------------------------
.../org/apache/beam/sdk/testing/PAssert.java | 5 ++
.../beam/sdk/transforms/ApproximateUnique.java | 4 +-
.../org/apache/beam/sdk/transforms/Combine.java | 10 ++--
.../apache/beam/sdk/transforms/CombineFns.java | 2 +
.../org/apache/beam/sdk/transforms/Create.java | 2 +-
.../apache/beam/sdk/transforms/Distinct.java | 2 +
.../apache/beam/sdk/transforms/DoFnTester.java | 27 +++++++----
.../beam/sdk/transforms/FlatMapElements.java | 14 ++++--
.../apache/beam/sdk/transforms/MapElements.java | 14 ++++--
.../org/apache/beam/sdk/transforms/Max.java | 5 +-
.../org/apache/beam/sdk/transforms/Min.java | 8 ++--
.../apache/beam/sdk/transforms/PTransform.java | 7 +--
.../org/apache/beam/sdk/transforms/Top.java | 5 +-
.../org/apache/beam/sdk/transforms/View.java | 7 +--
.../org/apache/beam/sdk/transforms/Watch.java | 4 +-
.../apache/beam/sdk/transforms/WithKeys.java | 6 ++-
.../sdk/transforms/display/DisplayData.java | 12 ++---
.../sdk/transforms/display/package-info.java | 4 ++
.../beam/sdk/transforms/join/CoGbkResult.java | 7 ++-
.../transforms/join/KeyedPCollectionTuple.java | 10 ++--
.../beam/sdk/transforms/join/RawUnionValue.java | 8 ++--
.../beam/sdk/transforms/join/package-info.java | 4 ++
.../beam/sdk/transforms/package-info.java | 4 ++
.../reflect/ByteBuddyDoFnInvokerFactory.java | 3 +-
.../sdk/transforms/reflect/DoFnInvoker.java | 50 ++++++++++++++++----
.../sdk/transforms/reflect/DoFnSignatures.java | 1 +
.../sdk/transforms/reflect/package-info.java | 3 ++
.../splittabledofn/OffsetRangeTracker.java | 5 +-
.../transforms/splittabledofn/package-info.java | 4 ++
.../windowing/IncompatibleWindowException.java | 2 +-
.../MergeOverlappingIntervalWindows.java | 4 +-
.../beam/sdk/transforms/windowing/Trigger.java | 20 ++++----
.../beam/sdk/transforms/windowing/Window.java | 1 +
.../sdk/transforms/windowing/package-info.java | 4 ++
.../transforms/reflect/DoFnInvokersTest.java | 12 ++++-
sdks/java/extensions/sql/pom.xml | 5 ++
.../extensions/sql/example/BeamSqlExample.java | 45 ++++++++++--------
.../impl/transform/BeamBuiltinAggregations.java | 10 +++-
.../sdk/nexmark/queries/NexmarkQueryModel.java | 5 +-
.../apache/beam/sdk/nexmark/queries/Query8.java | 3 +-
.../beam/sdk/nexmark/queries/WinningBids.java | 3 +-
41 files changed, 244 insertions(+), 107 deletions(-)
----------------------------------------------------------------------