Compartir tecnología

55. Explicación detallada del uso de expresiones Java Lambda en Flink

2024-07-08

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

1. Información general
1. Atención

Flink admite el uso de expresiones Lambda para todos los operadores de la API de Java. Sin embargo, cuando la expresión Lambda usa genéricos de Java, es necesario. explícito Declarar información de tipo.

2. Ejemplos y limitaciones

Ejemplo: map() La función utiliza una expresión Lambda para elevar al cuadrado el valor de entrada.

No se requiere declaración map() entrada de funcióni y tipos de datos de parámetros de salida, tal como los infiere el compilador de Java.

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