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 <[email protected]> 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(-)
