[jira] [Created] (FLINK-1110) Add a serial collection-based execution mode

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-1110) Add a serial collection-based execution mode

Shang Yuanchun (Jira)
Stephan Ewen created FLINK-1110:
-----------------------------------

             Summary: Add a serial collection-based execution mode
                 Key: FLINK-1110
                 URL: https://issues.apache.org/jira/browse/FLINK-1110
             Project: Flink
          Issue Type: Improvement
            Reporter: Stephan Ewen
            Priority: Minor


Summary of mailing list thread that the issue is based upon

Since Flink is a layered system, programs written against the APIs can be executed in a variety of ways. In this case, we just run the functions single-threaded directly on the Java collections, instead of firing up a memory management, IPC, parallel workers, data movement, etc. That gives programs a minimal execution footprint (like in the Java8 streams API) for small data. The idea is to enable users to use the same program in all sorts of different contexts.

The collection execution should sit below the common API, so both Java and Scala API can use it.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)