Java Lambda 表达式

    本文档介绍如何使用 Lambda 表达式并描述了其(Lambda 表达式)当前的限制。有关 Flink API 的通用介绍,请参阅 DataStream API 编程指南

    不需要声明 map() 函数的输入 i 和输出参数的数据类型,因为 Java 编译器会对它们做出推断。

    由于 OUT 是 而不是泛型,所以 Flink 可以从方法签名 OUT map(IN value) 的实现中自动提取出结果的类型信息。

    Flink 很可能抛出如下异常:

    在这种情况下,需要 显式 指定类型信息,否则输出将被视为 Object 类型,这会导致低效的序列化。

    一般来说,这些问题可以通过多种方式解决: