[
https://issues.apache.org/jira/browse/BEAM-4128?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Maximilian Michels resolved BEAM-4128.
--------------------------------------
Resolution: Not A Problem
Fix Version/s: Not applicable
To my best knowledge this is already the case. The opposite is actually true,
i.e. we can't translate custom window functions. There is BEAM-4296 to fix that.
> Handle WindowInto transforms in portable Flink runner directly
> --------------------------------------------------------------
>
> Key: BEAM-4128
> URL: https://issues.apache.org/jira/browse/BEAM-4128
> Project: Beam
> Issue Type: New Feature
> Components: runner-flink
> Reporter: Ben Sidhom
> Assignee: Aljoscha Krettek
> Priority: Major
> Fix For: Not applicable
>
>
> This is mostly an optimization, but by having the runner itself handle
> well-known WindowFns (e.g., global windowing, fixed windowing), we can avoid
> round trips to the SDK harness. This requires some pipeline surgery
> pre-translation if we want it to work efficiently in conjunction with fusion.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
