stankiewicz commented on code in PR #36962:
URL: https://github.com/apache/beam/pull/36962#discussion_r2643927298
##########
sdks/java/core/src/main/java/org/apache/beam/sdk/values/WindowedValues.java:
##########
@@ -918,6 +1004,10 @@ public void encode(WindowedValue<T> windowedElem,
OutputStream outStream, Contex
if (metadataSupported) {
BeamFnApi.Elements.ElementMetadata.Builder builder =
BeamFnApi.Elements.ElementMetadata.newBuilder();
+ io.opentelemetry.context.Context context1 = windowedElem.getContext();
Review Comment:
renamed. actually full class name is needed here.
##########
sdks/java/core/src/main/java/org/apache/beam/sdk/values/WindowedValues.java:
##########
@@ -933,16 +1023,18 @@ public void encode(WindowedValue<T> windowedElem,
OutputStream outStream, Contex
@Override
public WindowedValue<T> decode(InputStream inStream) throws
CoderException, IOException {
- return decode(inStream, Context.NESTED);
+ return decode(inStream, org.apache.beam.sdk.coders.Coder.Context.NESTED);
}
@Override
- public WindowedValue<T> decode(InputStream inStream, Context context)
+ public WindowedValue<T> decode(
+ InputStream inStream, org.apache.beam.sdk.coders.Coder.Context context)
Review Comment:
fixed
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
