Aljoscha Krettek created BEAM-253:
-------------------------------------
Summary: Unify Flink Operator Wrappers
Key: BEAM-253
URL: https://issues.apache.org/jira/browse/BEAM-253
Project: Beam
Issue Type: Improvement
Components: runner-flink
Reporter: Aljoscha Krettek
Right now, we have {{FlinkAbstractParDoWrapper}} with subclasses
{{FlinkParDoBoundWrapper}} and {{FlinkParDoBoundMultiWrapper}} as well as
{{FlinkGroupAlsoByWindowWrapper}}. They do essentially the same thing, but
slightly differently. The first three are implemented as a {{FlatMapFunction}}
while the latter is implemented as a {{StreamOperator}} (which is more
low-level and gives access to state and timers and such).
We should unify this into one wrapper. (With possibly a more concise name...)
In the process of this we should also make sure that we always use a
{{DoFnRunner}} via {{DoFnRunners.createDefault}}. This will help reduce bugs
such as [BEAM-241].
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
