Details
-
Improvement
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
None
-
None
Description
In order to be able to fully serialize the user DAG in high-level APIs, we need to make sure that the user-supplied functions are serializable as well. This will enable:
- Deserialize and instantiation of per-task user functions become completely managed by the system. No need to invoke StreamApplication.init() in each task
- Fully serialized user DAG can be distributed across the network to multiple containers
Attachments
Attachments
Issue Links
- links to