From a2aeb3c95485dd8d50d6335a2f51c1686e3db200 Mon Sep 17 00:00:00 2001 From: Radek Stankiewicz Date: Tue, 5 May 2026 15:54:21 +0200 Subject: [PATCH] fix error prone. --- .../apache/beam/sdk/values/ValueInSingleWindow.java | 12 +++++++----- 1 file changed, 7 insertions(+), 5 deletions(-) diff --git a/sdks/java/core/src/main/java/org/apache/beam/sdk/values/ValueInSingleWindow.java b/sdks/java/core/src/main/java/org/apache/beam/sdk/values/ValueInSingleWindow.java index 4cb8b920d64f..afd5aa845200 100644 --- a/sdks/java/core/src/main/java/org/apache/beam/sdk/values/ValueInSingleWindow.java +++ b/sdks/java/core/src/main/java/org/apache/beam/sdk/values/ValueInSingleWindow.java @@ -119,12 +119,14 @@ public static Coder of( @Override public void encode(ValueInSingleWindow windowedElem, OutputStream outStream) throws IOException { - encode(windowedElem, outStream, Coder.Context.NESTED); + encode(windowedElem, outStream, org.apache.beam.sdk.coders.Coder.Context.NESTED); } @Override public void encode( - ValueInSingleWindow windowedElem, OutputStream outStream, Coder.Context context) + ValueInSingleWindow windowedElem, + OutputStream outStream, + org.apache.beam.sdk.coders.Coder.Context context) throws IOException { InstantCoder.of().encode(windowedElem.getTimestamp(), outStream); windowCoder.encode(windowedElem.getWindow(), outStream); @@ -154,13 +156,13 @@ public void encode( @Override public ValueInSingleWindow decode(InputStream inStream) throws IOException { - return decode(inStream, Coder.Context.NESTED); + return decode(inStream, org.apache.beam.sdk.coders.Coder.Context.NESTED); } @Override @SuppressWarnings("IgnoredPureGetter") - public ValueInSingleWindow decode(InputStream inStream, Coder.Context context) - throws IOException { + public ValueInSingleWindow decode( + InputStream inStream, org.apache.beam.sdk.coders.Coder.Context context) throws IOException { Instant timestamp = InstantCoder.of().decode(inStream); BoundedWindow window = windowCoder.decode(inStream); PaneInfo paneInfo = PaneInfo.PaneInfoCoder.INSTANCE.decode(inStream);