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

Reply via email to