Details
-
Sub-task
-
Status: Resolved
-
P2
-
Resolution: Fixed
-
None
-
None
Description
Output elements from joining user-defined functions are collected using `SingleValueCollector`, so only one output value is supported. That is wrong limitation. Refactor 'DoFnCollector' to be universally usable to collect many elements with custom adaptation.