[
https://issues.apache.org/jira/browse/FLINK-1280?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14263990#comment-14263990
]
Márton Balassi commented on FLINK-1280:
---------------------------------------
After reconsideration this idea has been dropped.
> 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)
