Aljoscha Krettek created BEAM-956: ------------------------------------- Summary: Execute ReduceFnRunner Directly in Flink Runner Key: BEAM-956 URL: https://issues.apache.org/jira/browse/BEAM-956 Project: Beam Issue Type: Improvement Components: runner-flink Reporter: Aljoscha Krettek
Right now, a {{ReduceFnRunner}} is executed via {{GroupAlsoByWindowViaWindowSetDoFn}} which in turn is executed via a {{DoFnRunner}}. We should change that to get rid of the dependence on {{GroupAlsoByWindowViaWindowSetDoFn}} which is an {{OldDoFn}} and also to get rid of some unneeded layering. -- This message was sent by Atlassian JIRA (v6.3.4#6332)