[
https://issues.apache.org/jira/browse/FLINK-1280?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-1280.
-----------------------------
Resolution: Invalid
> Rework StreamInvokables to use the PactDriver interface for better future
> integration
> -------------------------------------------------------------------------------------
>
> Key: FLINK-1280
> URL: https://issues.apache.org/jira/browse/FLINK-1280
> Project: Flink
> Issue Type: Improvement
> Components: Streaming
> Reporter: Gyula Fora
> Priority: Minor
>
> The streaming runtime currently uses the StreamInvokable classes to execute
> user defined functions for the different operators. This basically the same
> thing as the PactDriver in the batch runtime.
> The StreamInvokables should be removed and stream operators should be
> implemented as PactDrivers to make integration between the two apis better.
> This would also allow us to reuse some drivers like map, flatmap in both apis.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
