AI_SUMMARIZE é uma função com valor de tabela que chama um large language model (LLM) para gerar um resumo textual de uma string de entrada.
Limitações
Requer Ververica Runtime (VVR) 11,4 ou posterior.
O uso do service Flink AI (modelos integrados) exige VVR 11,7 ou posterior e a ativação do service Flink AI. Para mais detalhes, consulte Flink AI service (built-in models).
As restrições de taxa da plataforma de modelo subjacente limitam o throughput. Ao atingir esses limites, o job Flink sofre backpressure e a função
AI_SUMMARIZEtorna-se o gargalo. Em casos graves, isso provoca erros de timeout e reinicializações do job.
Sintaxe
AI_SUMMARIZE(
MODEL => MODEL <model_name>,
INPUT => <input_column>,
MAX_LENGTH => <max_length>
)Compatível com estilos de argumentos posicionais e nomeados.
Parâmetros
|
Parâmetro |
Tipo de dados |
Descrição |
|
|
MODEL |
Nome do service de modelo registrado. O modelo deve retornar saída do tipo |
|
|
STRING |
Coluna cujo conteúdo o modelo resume. |
|
|
INTEGER |
Comprimento máximo da saída do modelo. Deve ser um valor constante. |
Saída
|
Coluna |
Tipo de dados |
Descrição |
|
|
STRING |
Resumo gerado pela função. |
Exemplos
Exemplo completo com dados de tabela
O exemplo abaixo utiliza um modelo integrado do Flink, carrega dados de teste em uma visualização temporária e invoca AI_SUMMARIZE em uma coluna da tabela, demonstrando os estilos de argumentos posicionais e nomeados.
Dados de teste
|
id |
description |
|
1 |
What is Flink? Apache Flink is an open source distributed stream processing framework for stateful computation over real-time data streams and batch data. In simple terms: Flink is a compute engine for processing real-time data. It handles continuous data streams such as website clicks, Internet of Things sensor data, and stock trades. It provides low latency, high throughput, and exactly-once semantics. It supports both stream processing and batch processing. |
SQL
CREATE TEMPORARY MODEL general_model
INPUT (`input` STRING)
OUTPUT (`content` VARIANT)
WITH (
'provider' = 'openai-compat',
'task' = 'chat/completions',
'model' = 'qwen3.6-flash'
);
CREATE TEMPORARY VIEW infos(id, description)
AS VALUES (1, '
What is Flink?
Apache Flink is an open source distributed stream processing framework for stateful computation over real-time data streams and batch data.
In simple terms:
Flink is a compute engine for processing real-time data.
It handles continuous data streams such as website clicks, Internet of Things sensor data, and stock trades.
It provides low latency, high throughput, and exactly-once semantics.
It supports both stream processing and batch processing.
');
-- Positional argument style
SELECT id, summary
FROM infos, LATERAL TABLE(
AI_SUMMARIZE(MODEL general_model, description, 10));
-- Named argument style
SELECT id, summary
FROM infos, LATERAL TABLE(
AI_SUMMARIZE(
MODEL => MODEL general_model,
INPUT => description,
MAX_LENGTH => 10));Saída
|
id |
summary |
|
1 |
Real-time stream processing engine |