Robert Bradshaw created BEAM-6294:
-------------------------------------
Summary: Use Flink's redistribute for reshuffle.
Key: BEAM-6294
URL: https://issues.apache.org/jira/browse/BEAM-6294
Project: Beam
Issue Type: New Feature
Components: runner-flink, sdk-py-core
Reporter: Robert Bradshaw
Assignee: Robert Bradshaw
Python needs to publish the URN over the FnAPI which is pretty easy, but Flink
also needs to ensure that the composite structure does not get fused. Unlike
with GBK, we can't assume all runners implement this as a primitive.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
