This is an automated email from the ASF dual-hosted git repository.
kenn pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
from 534e1cb0dbf Add artifactregistry.writer to service account (#36756)
add 0ab2d039f8d Add @Pure annotations to Preconditions
add e84b318ad3c Add @Pure annotations to DoFnSignature
add a33d59420c7 Add @Pure annotations to DoFnSchemaInformation
add 8f5bc796213 Add @Pure annotations to TimerSpec
add edad6545dad Add @Pure annotations to SideInputReader
add 6c99f7ceb71 Add @Pure annotations to LateDataUtils
add f07ca33e355 Fix nullness errors in SimpleDoFnRunner and DoFnInvoker
add 87530a369fb Trivial change to KafkaSourceConsumerFnTest to eliminate
warning
add be65cfe8d78 Fix nullness of currentRecordId and currentRecordOffset
add 2a06694cc5e Merge pull request #35029: Fix nullness errors in
SimpleDoFnRunner and DoFnInvoker
No new revisions were added by this update.
Summary of changes:
.../apache/beam/runners/core/LateDataUtils.java | 3 +
...TimeBoundedSplittableProcessElementInvoker.java | 4 +-
.../apache/beam/runners/core/SideInputReader.java | 13 +-
.../apache/beam/runners/core/SimpleDoFnRunner.java | 169 ++++++++++++++++-----
.../java/org/apache/beam/sdk/state/TimerSpec.java | 2 +
.../java/org/apache/beam/sdk/transforms/DoFn.java | 4 +-
.../beam/sdk/transforms/DoFnSchemaInformation.java | 6 +
.../beam/sdk/transforms/reflect/DoFnInvoker.java | 28 +++-
.../beam/sdk/transforms/reflect/DoFnSignature.java | 108 +++++++++++++
.../org/apache/beam/sdk/util/Preconditions.java | 31 ++++
.../io/debezium/KafkaSourceConsumerFnTest.java | 2 +-
11 files changed, 311 insertions(+), 59 deletions(-)
