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);