Gyula Fora created FLINK-1280:
---------------------------------
Summary: 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)
