AI_SUMMARIZE - Realtime Compute for Apache Flink - Centro de documentación de Alibaba Cloud

AI_SUMMARIZE es una función con valor de tabla que llama a un modelo de lenguaje grande (LLM) para generar el resumen de texto de una cadena de entrada.

Límites

Requiere Ververica Runtime (VVR) 11.4 o posterior.
Para usar el servicio Flink AI (modelos integrados), se requiere VVR 11.7 o posterior y debe activar el servicio Flink AI. Para más detalles, consulte Servicio Flink AI (modelos integrados).
El rendimiento está limitado por las restricciones de velocidad de la plataforma del modelo subyacente. Cuando se alcanzan esos límites, el trabajo de Flink experimenta contrapresión y AI_SUMMARIZE se convierte en el cuello de botella. En casos graves, esto provoca errores de tiempo de espera agotado y reinicios del trabajo.

Sintaxis

AI_SUMMARIZE(
  MODEL => MODEL <model_name>,
  INPUT => <input_column>,
  MAX_LENGTH => <max_length>
)

Parámetros

Parámetro	Tipo de dato	Descripción
`MODEL <model_name>`	MODEL	Nombre del servicio de modelos registrado. El modelo debe devolver una salida de tipo `VARIANT`. Consulte Model Settings para registrar un servicio de modelos.
`<input_column>`	STRING	Columna cuyo contenido resume el modelo.
`<max_length>`	INTEGER	Longitud máxima de la salida del modelo. Debe ser un valor constante.

Valores de retorno

Columna	Tipo de dato	Descripción
`summary`	STRING	Resumen generado.

Ejemplos

Datos de prueba

descripción

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.

Instrucciones SQL

A continuación se muestra un ejemplo que hace referencia a un modelo integrado de Flink y utiliza AI_SUMMARIZE para resumir los datos de entrada.

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));

Salida

id	resumen
1	Real-time stream processing engine