[
https://issues.apache.org/jira/browse/APEXMALHAR-2481?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15980170#comment-15980170
]
Thomas Weise commented on APEXMALHAR-2481:
------------------------------------------
{code}
StreamFactory.fromFolder("/tmp")
.flatMap((FlatMapFunction<String, String> & Serializable)(input) ->
Arrays.asList(input.split("\\s+")))
.print()
.populateDag(dag);
{code}
This is an example that also makes the lambda Java serializable, but the
operator is using Kryo. Since Java serialization supports lambda, the operator
should probably be changed to use it.
> High Level Stream API does not support lambda expressions
> ---------------------------------------------------------
>
> Key: APEXMALHAR-2481
> URL: https://issues.apache.org/jira/browse/APEXMALHAR-2481
> Project: Apache Apex Malhar
> Issue Type: Bug
> Affects Versions: 3.7.0
> Reporter: Thomas Weise
>
> The API does not work with Java 8 lambda expressions because the operator
> deserialization fails.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
