Hi,

As part of removing remaining OldDoFn reliance in ApexRunner I'm looking
for the DoFn replacement for
org.apache.beam.runners.core.AssignWindowsDoFn, specifically the equivalent
of context.outputWindowedValue.

https://github.com/apache/beam/blob/master/runners/apex/src/main/java/org/apache/beam/runners/apex/translation/WindowAssignTranslator.java#L52

Looking elsewhere suggests that this isn't done using a DoFn (and reuse
respective execution operator)? If that's confirmed, then I can also create
a new operator for this.

Thanks

Reply via email to