Hi all, I've been working on migrating the Spark runner to new DoFn and I've stumbled upon a couple of cases where OldDoFn is used in a way that accessed windowInternals (outputWindowedValue) such as AssignWindowsDoFn.
Since changing windows is no longer the responsibility of DoFn I was wondering who and how is this done. Thanks, Amit