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 2026/07/27 23:36:37 UTC
(beam) branch master updated (1d25d3b75a4 -> 405438b83fe)
This is an automated email from the ASF dual-hosted git repository.
kennknowles pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
from 1d25d3b75a4 Merge pull request #39463: Remove @DefaultAnnotation(NonNull.class) throughout project - it is already default
add fdac189a032 Fix nullness for PubsubIO
new 405438b83fe Merge pull request #39444: Fix nullness for PubsubIO
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../sdk/io/gcp/pubsub/AddTimestampAttribute.java | 13 +-
.../beam/sdk/io/gcp/pubsub/ExternalWrite.java | 15 +-
.../beam/sdk/io/gcp/pubsub/NestedRowToMessage.java | 8 +-
.../io/gcp/pubsub/PubSubPayloadTranslation.java | 46 ++---
.../beam/sdk/io/gcp/pubsub/PubsubClient.java | 59 ++++---
.../beam/sdk/io/gcp/pubsub/PubsubGrpcClient.java | 47 ++---
.../apache/beam/sdk/io/gcp/pubsub/PubsubIO.java | 171 ++++++++++++-------
.../beam/sdk/io/gcp/pubsub/PubsubJsonClient.java | 100 ++++++-----
.../beam/sdk/io/gcp/pubsub/PubsubMessage.java | 23 ++-
.../beam/sdk/io/gcp/pubsub/PubsubMessageToRow.java | 42 +++--
...hAttributesAndMessageIdAndOrderingKeyCoder.java | 19 ++-
...bsubMessageWithAttributesAndMessageIdCoder.java | 14 +-
.../pubsub/PubsubMessageWithAttributesCoder.java | 9 +-
.../pubsub/PubsubMessageWithMessageIdCoder.java | 9 +-
.../pubsub/PubsubReadSchemaTransformProvider.java | 34 ++--
.../beam/sdk/io/gcp/pubsub/PubsubRowToMessage.java | 58 ++++---
.../sdk/io/gcp/pubsub/PubsubSchemaIOProvider.java | 51 +++---
.../beam/sdk/io/gcp/pubsub/PubsubTestClient.java | 118 ++++++++-----
.../sdk/io/gcp/pubsub/PubsubUnboundedSink.java | 62 ++++---
.../sdk/io/gcp/pubsub/PubsubUnboundedSource.java | 190 +++++++++++++--------
.../pubsub/PubsubWriteSchemaTransformProvider.java | 59 ++++---
.../apache/beam/sdk/io/gcp/pubsub/TestPubsub.java | 92 ++++++----
.../beam/sdk/io/gcp/pubsub/TestPubsubSignal.java | 79 +++++----
23 files changed, 788 insertions(+), 530 deletions(-)
(beam) 01/01: Merge pull request #39444: Fix nullness for PubsubIO
Posted by ke...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
kennknowles pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit 405438b83fed2ced15d5c1d5df090493fe08ea44
Merge: 1d25d3b75a4 fdac189a032
Author: Kenneth Knowles <kl...@google.com>
AuthorDate: Mon Jul 27 19:36:29 2026 -0400
Merge pull request #39444: Fix nullness for PubsubIO
.../sdk/io/gcp/pubsub/AddTimestampAttribute.java | 13 +-
.../beam/sdk/io/gcp/pubsub/ExternalWrite.java | 15 +-
.../beam/sdk/io/gcp/pubsub/NestedRowToMessage.java | 8 +-
.../io/gcp/pubsub/PubSubPayloadTranslation.java | 46 ++---
.../beam/sdk/io/gcp/pubsub/PubsubClient.java | 59 ++++---
.../beam/sdk/io/gcp/pubsub/PubsubGrpcClient.java | 47 ++---
.../apache/beam/sdk/io/gcp/pubsub/PubsubIO.java | 171 ++++++++++++-------
.../beam/sdk/io/gcp/pubsub/PubsubJsonClient.java | 100 ++++++-----
.../beam/sdk/io/gcp/pubsub/PubsubMessage.java | 23 ++-
.../beam/sdk/io/gcp/pubsub/PubsubMessageToRow.java | 42 +++--
...hAttributesAndMessageIdAndOrderingKeyCoder.java | 19 ++-
...bsubMessageWithAttributesAndMessageIdCoder.java | 14 +-
.../pubsub/PubsubMessageWithAttributesCoder.java | 9 +-
.../pubsub/PubsubMessageWithMessageIdCoder.java | 9 +-
.../pubsub/PubsubReadSchemaTransformProvider.java | 34 ++--
.../beam/sdk/io/gcp/pubsub/PubsubRowToMessage.java | 58 ++++---
.../sdk/io/gcp/pubsub/PubsubSchemaIOProvider.java | 51 +++---
.../beam/sdk/io/gcp/pubsub/PubsubTestClient.java | 118 ++++++++-----
.../sdk/io/gcp/pubsub/PubsubUnboundedSink.java | 62 ++++---
.../sdk/io/gcp/pubsub/PubsubUnboundedSource.java | 190 +++++++++++++--------
.../pubsub/PubsubWriteSchemaTransformProvider.java | 59 ++++---
.../apache/beam/sdk/io/gcp/pubsub/TestPubsub.java | 92 ++++++----
.../beam/sdk/io/gcp/pubsub/TestPubsubSignal.java | 79 +++++----
23 files changed, 788 insertions(+), 530 deletions(-)