Traduit une colonne de texte dans une tâche Flink SQL à l'aide d'un grand modèle de langage (LLM).
Limitations
Ververica Runtime (VVR) 11.4 ou version ultérieure est requis.
Pour utiliser le service Flink AI (modèles intégrés), vous devez disposer de VVR 11.7 ou version ultérieure et activer le service Flink AI. Pour plus d'informations, consultez Flink AI service (built-in models).
Le débit est limité par la plateforme de modèles. Si cette limite est dépassée, la tâche Flink subit une contre-pression et cet opérateur devient un goulot d'étranglement. Une limitation stricte du débit déclenche des erreurs de délai d'attente et provoque le redémarrage de la tâche.
Syntaxe
AI_TRANSLATE(
MODEL => MODEL <MODEL NAME>,
INPUT => <INPUT COLUMN NAME>,
SOURCE_LANG => <SOURCE LANGUAGE>,
TARGET_LANG => <TARGET LANGUAGE>
)Paramètres
| Paramètre | Type de données | Description |
|---|---|---|
MODEL <MODEL NAME> |
MODEL | Nom du service de modèle enregistré. Pour plus d'informations, consultez Model settings. Le type de sortie de ce modèle doit être VARIANT. |
<INPUT COLUMN NAME> |
STRING | Texte source à traduire. |
<SOURCE LANGUAGE> |
STRING | Code de langue du texte source (par exemple, zh pour le chinois). Indiquez auto pour permettre au modèle de détecter automatiquement la langue. Doit être une constante. |
<TARGET LANGUAGE> |
STRING | Code de langue cible (par exemple, zh pour le chinois). Doit être une constante. |
Les langues prises en charge dépendent du modèle que vous enregistrez.
Langues prises en charge
| Langue | Code |
|---|---|
| Arabe | ar |
| Chinois | zh |
| Anglais | en |
| Français | fr |
| Allemand | de |
| Japonais | ja |
| Coréen | ko |
| Portugais | pt |
| Russe | ru |
| Espagnol | es |
Valeurs de retour
| Champ | Type de données | Description |
|---|---|---|
translated_text |
STRING | Texte traduit. |
detected_language |
STRING | Langue source détectée. |
Exemples
Les exemples suivants utilisent un modèle intégré Flink et la fonction AI_TRANSLATE pour traduire du texte anglais en chinois. Les syntaxes avec arguments positionnels et nommés sont présentées.
Données de test
| id | content |
|---|---|
| 1 | I like Flink very much. It's so fast! |
Instructions 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'
));Sortie
| id | translated_text | detected_language |
|---|---|---|
| 1 | I like Flink very much. It's very fast! | en |