Luke Cwik created BEAM-10420:
--------------------------------
Summary: PerWindowInvoker to handle window observing
SplittableDoFns
Key: BEAM-10420
URL: https://issues.apache.org/jira/browse/BEAM-10420
Project: Beam
Issue Type: Improvement
Components: sdk-java-harness
Reporter: Luke Cwik
Assignee: Luke Cwik
Currently the FnApiDoFnRunner processes each element within it's own window.
There is an easy optimization where we process the element once if and only if
the function doesn't observe the window (either directly or indirectly via side
inputs/state/...).
--
This message was sent by Atlassian Jira
(v8.3.4#803005)