You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ah...@apache.org on 2025/12/22 19:19:06 UTC
(beam) branch master updated: make pulsar getters public (#37169)
This is an automated email from the ASF dual-hosted git repository.
ahmedabualsaud pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push:
new c5112609071 make pulsar getters public (#37169)
c5112609071 is described below
commit c511260907188aef46e9088ab4ce5eb5ee5b0adf
Author: Ahmed Abualsaud <65...@users.noreply.github.com>
AuthorDate: Mon Dec 22 13:18:58 2025 -0600
make pulsar getters public (#37169)
---
.../java/org/apache/beam/sdk/io/pulsar/PulsarMessage.java | 12 ++++++------
1 file changed, 6 insertions(+), 6 deletions(-)
diff --git a/sdks/java/io/pulsar/src/main/java/org/apache/beam/sdk/io/pulsar/PulsarMessage.java b/sdks/java/io/pulsar/src/main/java/org/apache/beam/sdk/io/pulsar/PulsarMessage.java
index 739d34c9860..326671ad8fc 100644
--- a/sdks/java/io/pulsar/src/main/java/org/apache/beam/sdk/io/pulsar/PulsarMessage.java
+++ b/sdks/java/io/pulsar/src/main/java/org/apache/beam/sdk/io/pulsar/PulsarMessage.java
@@ -31,19 +31,19 @@ import org.checkerframework.checker.nullness.qual.Nullable;
@DefaultSchema(AutoValueSchema.class)
@AutoValue
public abstract class PulsarMessage {
- abstract @Nullable String getTopic();
+ public abstract @Nullable String getTopic();
- abstract long getPublishTimestamp();
+ public abstract long getPublishTimestamp();
- abstract @Nullable String getKey();
+ public abstract @Nullable String getKey();
@SuppressWarnings("mutable")
- abstract byte[] getValue();
+ public abstract byte[] getValue();
- abstract @Nullable Map<String, String> getProperties();
+ public abstract @Nullable Map<String, String> getProperties();
@SuppressWarnings("mutable")
- abstract byte[] getMessageId();
+ public abstract byte[] getMessageId();
public static PulsarMessage create(
@Nullable String topicName,