Обмен технологиями

55. Подробное объяснение использования выражений Java Lambda в Flink.

2024-07-08

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

1 Обзор
1. Внимание

Flink поддерживает использование лямбда-выражений для всех операторов Java API. Однако, если в лямбда-выражении используются дженерики Java, вам необходимо это сделать. явный Объявите информацию о типе.

2. Примеры и ограничения

Пример: map() Функция использует лямбда-выражение для возведения в квадрат входного значения.

Декларация не требуется map() ввод функцииi и типы данных выходных параметров, как их определяет компилятор Java.

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