A função AI_TRANSLATE usa um operador Flink para traduzir textos multilíngues com base em um service de modelo e parâmetros de idioma especificados. Problemas de backpressure ou timeout podem ocorrer devido ao limitador de taxa na plataforma do modelo. - Realtime Compute for Apache Flink: Central de Documentação do Alibaba Cloud

Limitações

Requer Ververica Runtime (VVR) 11.4 ou posterior.
Para usar o Flink AI service (modelos integrados), é necessário ter o VVR 11.7 ou posterior e ativar o Flink AI service. Para mais detalhes, consulte Flink AI service (modelos integrados).
O throughput está sujeito às restrições de taxa da plataforma do modelo. Ao ultrapassar esse limite, o job Flink sofre backpressure e este operador se torna um gargalo. Restrições severas de taxa provocam erros de timeout e reiniciam o job.

Sintaxe

AI_TRANSLATE(
  MODEL => MODEL <MODEL NAME>,
  INPUT => <INPUT COLUMN NAME>,
  SOURCE_LANG => <SOURCE LANGUAGE>,
  TARGET_LANG => <TARGET LANGUAGE>
)

Parâmetros

Parâmetro	Tipo de dados	Descrição
`MODEL <MODEL NAME>`	MODEL	Nome do service de modelo registrado. Para mais informações, consulte Model settings. O tipo de saída deste modelo deve ser `VARIANT`.
`<INPUT COLUMN NAME>`	STRING	Texto de origem a traduzir.
`<SOURCE LANGUAGE>`	STRING	Código do idioma do texto de origem (por exemplo, `zh` para chinês). Use `auto` para permitir que o modelo detecte o idioma automaticamente. Deve ser uma constante.
`<TARGET LANGUAGE>`	STRING	Código do idioma de destino (por exemplo, `zh` para chinês). Deve ser uma constante.

Os idiomas compatíveis dependem do modelo registrado.

Idiomas compatíveis

Idioma	Código
Árabe	`ar`
Chinês	`zh`
Inglês	`en`
Francês	`fr`
Alemão	`de`
Japonês	`ja`
Coreano	`ko`
Português	`pt`
Russo	`ru`
Espanhol	`es`

Valores de retorno

Campo	Tipo de dados	Descrição
`translated_text`	STRING	Texto traduzido.
`detected_language`	STRING	Idioma de origem detectado.

Exemplos

Os exemplos abaixo usam um modelo integrado do Flink e a função AI_TRANSLATE para traduzir texto do inglês para o chinês. As sintaxes de argumentos posicionais e nomeados estão demonstradas.

Dados de teste

id	content
1	I like Flink very much. It's so fast!

Instruções 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, content)
AS VALUES (1, 'I like Flink very much. It''s so fast!');

-- Positional argument syntax
SELECT id, translated_text, detected_language
FROM infos,
LATERAL TABLE(
  AI_TRANSLATE(
    MODEL general_model,
    content,
    'auto',
    'zh'
  ));

-- Named argument syntax
SELECT id, translated_text, detected_language
FROM infos,
LATERAL TABLE(
  AI_TRANSLATE(
    MODEL => MODEL general_model,
    INPUT => content,
    SOURCE_LANG => 'auto',
    TARGET_LANG => 'zh'
  ));

Saída

id	translated_text	detected_language
1	I like Flink very much. It's very fast!	en