Compartilhamento de tecnologia

55. Explicação detalhada do uso de expressões Java Lambda no Flink

2024-07-08

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

1. Visão Geral
1. Atenção

Flink oferece suporte ao uso de expressões Lambda para todos os operadores da API Java. No entanto, quando a expressão Lambda usa genéricos Java, você precisa. explícito Declare informações de tipo.

2. Exemplos e Limitações

Exemplo: map() A função usa uma expressão Lambda para elevar ao quadrado o valor de entrada.

Não é necessária declaração map() entrada de funçãoi e tipos de dados de parâmetros de saída, conforme o compilador Java os infere.

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