Com a versão 2.1, o Apache Flink também agora suporta funções de tabela de processos (PTFs), o tipo mais poderoso de função da API do Flink SQL e da tabela, informou o PMC. Conceitualmente, um PTF é um superconjunto de todas as outras funções definidas pelo usuário, mapeando zero, uma ou várias tabelas para zero, uma ou várias linhas. Isso permite a implementação de operadores definidos pelo usuário que podem ser tão ricos em recursos quanto as operações internas, disse o PMC. Os PTFs têm acesso ao estado gerenciado, no evento, no evento, no evento de tabela e nos serviços de troca de tabela e nos serviços de timer.
Apache Flink 2.1 também adiciona VARIANT como tipo de dados para dados semiestruturados, como o JSON. Este novo tipo suporta armazenar quaisquer dados semiestruturados, incluindo ARRAYAssim, MAP (com STRING chaves) e tipos escalares enquanto preservam as informações do tipo de campo em uma estrutura do tipo JSON. Ao contrário do ROW e STRUCTURED tipos, VARIANT Fornece flexibilidade superior para lidar com esquemas profundamente aninhados e em evolução. Os usuários podem usar PARSE_JSON ou TRY_PARSE_JSON para converter JSON formatado VARCHAR dados para VARIANT.
Também no Apache Flink 2.1:
