Java Lambda 表达式
本文档介绍如何使用 Lambda 表达式并描述了其(Lambda 表达式)当前的限制。有关 Flink API 的通用介绍,请参阅 DataStream API 编程指南。
不需要声明 map()
函数的输入 i
和输出参数的数据类型,因为 Java 编译器会对它们做出推断。
由于 OUT
是 而不是泛型,所以 Flink 可以从方法签名 OUT map(IN value)
的实现中自动提取出结果的类型信息。
Flink 很可能抛出如下异常:
在这种情况下,需要 显式 指定类型信息,否则输出将被视为 Object
类型,这会导致低效的序列化。
一般来说,这些问题可以通过多种方式解决: