[jira] [Created] (FLINK-1280) Rework StreamInvokables to use the PactDriver interface for better future integration

[Shang Yuanchun (Jira)]

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)