flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Márton Balassi (JIRA) <j...@apache.org>
Subject [jira] [Commented] (FLINK-1280) Rework StreamInvokables to use the PactDriver interface for better future integration
Date Sun, 04 Jan 2015 20:25:34 GMT

    [ 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)

Mime
View raw message