Amit Sela created BEAM-1591:
-------------------------------
Summary: Implement Combine optimizations for GABW in streaming.
Key: BEAM-1591
URL: https://issues.apache.org/jira/browse/BEAM-1591
Project: Beam
Issue Type: Improvement
Components: runner-spark
Reporter: Amit Sela
This should be straight-forward.
Introduce {{AccumT}} generics in {{SparkGroupAlsoByWindowViaWindowSet}} and
call with {{InputT}} for GBK and {{AccumT}} with Combine.
Pass the proper {{SystemReduceFn}} instead of creating it in
{{SparkGroupAlsoByWindowViaWindowSet}}.
For combine, extract the output from the fired accumulated output.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
