2024-07-08
한어Русский языкEnglishFrançaisIndonesianSanskrit日本語DeutschPortuguêsΕλληνικάespañolItalianoSuomalainenLatina
Flink 支持对 Java API 的所有算子使用 Lambda 表达式,但是,当 Lambda 表达式使用 Java 泛型时,需要 显式 地声明类型信息。
示例: map()
函数使用 Lambda 表达式计算输入值的平方。
不需要声明 map()
函数的输入 i
和输出参数的数据类型,因为 Java 编译器会对它们做出推断。
env.fromElements(1, 2, 3)
// 返回 i 的平方
.map(i -