Technologieaustausch

55. Detaillierte Erläuterung der Verwendung von Java-Lambda-Ausdrücken in Flink

2024-07-08

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

1. Übersicht
1. Achtung

Flink unterstützt die Verwendung von Lambda-Ausdrücken für alle Operatoren der Java-API. Wenn der Lambda-Ausdruck jedoch Java-Generika verwendet, müssen Sie dies tun explizit Typinformationen deklarieren.

2. Beispiele und Einschränkungen

Beispiel: map() Die Funktion verwendet einen Lambda-Ausdruck, um den Eingabewert zu quadrieren.

Keine Erklärung erforderlich map() Funktionseingabei und Ausgabeparameter-Datentypen, wie sie vom Java-Compiler abgeleitet werden.

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