flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Nick Dimiduk (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-3148) Support configured serializers for shipping UDFs
Date Tue, 08 Dec 2015 18:37:11 GMT
Nick Dimiduk created FLINK-3148:
-----------------------------------

             Summary: Support configured serializers for shipping UDFs
                 Key: FLINK-3148
                 URL: https://issues.apache.org/jira/browse/FLINK-3148
             Project: Flink
          Issue Type: Improvement
            Reporter: Nick Dimiduk


Java 8 lambdas are very useful for expressing flow logic. However, their closures need to
be serialized to nodes in the cluster. Current implementation only uses Java Serialization,
which is limiting when integrating code from other projects. I propose reusing flink's existing
serialization mechanisms (POJO magic, Kryo, extensible, &c) for serializing UDF instances
as well.

Discussion: http://mail-archives.apache.org/mod_mbox/flink-user/201512.mbox/%3CCANZa%3DGuchEr60r4bFWARtepQ37ZivSUQn6A1-o2eT66_M%3DFW%2BA%40mail.gmail.com%3E



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

Mime
View raw message