Package org.apache.flink.cdc.runtime.functions.impl

Class AiFunctions

java.lang.Object

org.apache.flink.cdc.runtime.functions.impl.AiFunctions

public class AiFunctions
extends Object

Built-in AI functions available to transform expressions.

Method Summary

Modifier and Type	Method	Description
static BinaryVariant	aiClassify(String modelName, String input, String labels, Map<String,AiModelClient> modelClients)
static BinaryVariant	aiComplete(String modelName, String input, String systemPrompt, Map<String,AiModelClient> modelClients)
static List<Float>	aiEmbed(String modelName, String input, Map<String,AiModelClient> modelClients)
static BinaryVariant	aiExtract(String modelName, String input, String schema, Map<String,AiModelClient> modelClients)
static String	aiImageComplete(String modelName, byte[] image, String prompt, Map<String,AiModelClient> modelClients)	Dispatches image-to-text AI functions.
static List<Float>	aiImageEmbed(String modelName, byte[] image, Map<String,AiModelClient> modelClients)	Dispatches image embedding AI functions.
static BinaryVariant	aiMask(String modelName, String input, String entities, Map<String,AiModelClient> modelClients)
static BinaryVariant	aiSentiment(String modelName, String input, Map<String,AiModelClient> modelClients)
static BinaryVariant	aiSummarize(String modelName, String input, int maxLength, Map<String,AiModelClient> modelClients)
static BinaryVariant	aiTranslate(String modelName, String input, String sourceLang, String targetLang, Map<String,AiModelClient> modelClients)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

aiComplete

public static BinaryVariant aiComplete(String modelName,
                                       String input,
                                       String systemPrompt,
                                       Map<String,AiModelClient> modelClients)

aiClassify

public static BinaryVariant aiClassify(String modelName,
                                       String input,
                                       String labels,
                                       Map<String,AiModelClient> modelClients)

aiTranslate

public static BinaryVariant aiTranslate(String modelName,
                                        String input,
                                        String sourceLang,
                                        String targetLang,
                                        Map<String,AiModelClient> modelClients)

aiSummarize

public static BinaryVariant aiSummarize(String modelName,
                                        String input,
                                        int maxLength,
                                        Map<String,AiModelClient> modelClients)

aiSentiment

public static BinaryVariant aiSentiment(String modelName,
                                        String input,
                                        Map<String,AiModelClient> modelClients)

aiExtract

public static BinaryVariant aiExtract(String modelName,
                                      String input,
                                      String schema,
                                      Map<String,AiModelClient> modelClients)

aiMask

public static BinaryVariant aiMask(String modelName,
                                   String input,
                                   String entities,
                                   Map<String,AiModelClient> modelClients)

aiEmbed

public static List<Float> aiEmbed(String modelName,
                                  String input,
                                  Map<String,AiModelClient> modelClients)

aiImageComplete

public static String aiImageComplete(String modelName,
                                     byte[] image,
                                     String prompt,
                                     Map<String,AiModelClient> modelClients)

Dispatches image-to-text AI functions.

aiImageEmbed

public static List<Float> aiImageEmbed(String modelName,
                                       byte[] image,
                                       Map<String,AiModelClient> modelClients)

Dispatches image embedding AI functions.