技術共有

55. FlinkでのJava Lambda式の使用の詳細な説明

2024-07-08

한어Русский языкEnglishFrançaisIndonesianSanskrit日本語DeutschPortuguêsΕλληνικάespañolItalianoSuomalainenLatina

1。概要
1. 注意

Flink は、Java API のすべての演算子に対して Lambda 式の使用をサポートしています。ただし、Lambda 式で Java ジェネリックスを使用する場合は、次のことを行う必要があります。 明示的な 型情報を宣言します。

2. 例と制限事項

例: map() この関数はラムダ式を使用して入力値を 2 乗します。

申告は必要ありません map() 関数入力i Java コンパイラーが推論する出力パラメーターのデータ型。

env.fromElements(1, 2, 3)
// 返回 i 的平方
.map(i -