Details
-
Improvement
-
Status: Resolved
-
P2
-
Resolution: Fixed
-
None
-
None
Description
In some places the Spark runner uses both external windowing and internal windowing in collections such as
WindowedValue<KV<K, Iterable<WindowedValue<V>>>>
leading to unneeded mappers and dereference
The external windowing information is duplicated so unneeded
Attachments
Issue Links
- links to