From dba250ff392f6ac9218a380f7f468af75cdb8cf6 Mon Sep 17 00:00:00 2001 From: SubramanyaV Date: Fri, 17 Apr 2026 23:27:22 +0530 Subject: [PATCH 1/4] improved Coder documentation --- .../src/main/java/org/apache/beam/sdk/coders/Coder.java | 7 +++++++ 1 file changed, 7 insertions(+) diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/coders/Coder.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/coders/Coder.java index 0a3650ca133b..f85be0962d8a 100644 --- a/sdks/java/core/src/main/java/org/apache/beam/sdk/coders/Coder.java +++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/coders/Coder.java @@ -52,6 +52,13 @@ *

All methods of a {@link Coder} are required to be thread safe. * * @param the type of values being encoded and decoded + *

The behavior of encoding and decoding depends on the {@link Context}. + *

+ *

See {@link CoderProperties} for utilities to test coder correctness and consistency. */ public abstract class Coder implements Serializable { /** From bfd1a2d30ed81632faa5969e080b74dd04f27fdb Mon Sep 17 00:00:00 2001 From: SubramanyaV Date: Sat, 18 Apr 2026 08:31:07 +0530 Subject: [PATCH 2/4] fix: improved javadoc for Coder --- .../core/src/main/java/org/apache/beam/sdk/coders/Coder.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/coders/Coder.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/coders/Coder.java index f85be0962d8a..3954bedc9c08 100644 --- a/sdks/java/core/src/main/java/org/apache/beam/sdk/coders/Coder.java +++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/coders/Coder.java @@ -52,13 +52,14 @@ *

All methods of a {@link Coder} are required to be thread safe. * * @param the type of values being encoded and decoded - *

The behavior of encoding and decoding depends on the {@link Context}. + * + *

The behavior of encoding and decoding depends on the {@link Context}. *

- *

See {@link CoderProperties} for utilities to test coder correctness and consistency. + *

See {@link CoderProperties} for utilities to test coder correctness and consistency. */ public abstract class Coder implements Serializable { /** From fa4019b0493f219355d7fcfc4ff1eb8e961ff8f1 Mon Sep 17 00:00:00 2001 From: SubramanyaV Date: Sat, 18 Apr 2026 09:04:30 +0530 Subject: [PATCH 3/4] trigger ci after spotless fix --- .../core/src/main/java/org/apache/beam/sdk/coders/Coder.java | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/coders/Coder.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/coders/Coder.java index 3954bedc9c08..f85be0962d8a 100644 --- a/sdks/java/core/src/main/java/org/apache/beam/sdk/coders/Coder.java +++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/coders/Coder.java @@ -52,14 +52,13 @@ *

All methods of a {@link Coder} are required to be thread safe. * * @param the type of values being encoded and decoded - * - *

The behavior of encoding and decoding depends on the {@link Context}. + *

The behavior of encoding and decoding depends on the {@link Context}. *

- *

See {@link CoderProperties} for utilities to test coder correctness and consistency. + *

See {@link CoderProperties} for utilities to test coder correctness and consistency. */ public abstract class Coder implements Serializable { /** From c3d3c1e3fcc161655ca2f06b2b88bccc7d0041e0 Mon Sep 17 00:00:00 2001 From: SubramanyaV Date: Sat, 18 Apr 2026 11:36:39 +0530 Subject: [PATCH 4/4] improved javadoc for Coder file --- .../src/main/java/org/apache/beam/sdk/coders/Coder.java | 8 +++----- 1 file changed, 3 insertions(+), 5 deletions(-) diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/coders/Coder.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/coders/Coder.java index f85be0962d8a..75b2b206edd1 100644 --- a/sdks/java/core/src/main/java/org/apache/beam/sdk/coders/Coder.java +++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/coders/Coder.java @@ -53,11 +53,9 @@ * * @param the type of values being encoded and decoded *

The behavior of encoding and decoding depends on the {@link Context}. - *

+ *

In {@link Context#OUTER}, the value consumes the remainder of the stream. + *

In {@link Context#NESTED}, the value is part of a larger structure and must be + * self-delimiting so that subsequent values can be correctly decoded. *

See {@link CoderProperties} for utilities to test coder correctness and consistency. */ public abstract class Coder implements Serializable {