Xinyu Liu created BEAM-6253:
-------------------------------
Summary: SamzaRunner: Add a few customized transforms for runner
use cases
Key: BEAM-6253
URL: https://issues.apache.org/jira/browse/BEAM-6253
Project: Beam
Issue Type: Improvement
Components: runner-samza
Reporter: Xinyu Liu
Assignee: Xinyu Liu
A few customized transforms are needed in SamzaRunner to support the following
cases:
- allow GroupByKey/CoGroupByKey without repartitioning
- allow updating accumulation after firing a window pane
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
