Uses of Interface
org.apache.flink.cdc.common.model.AiModelClient

Packages that use AiModelClient

Package	Description
org.apache.flink.cdc.common.model
org.apache.flink.cdc.models.dummy
org.apache.flink.cdc.models.openai
org.apache.flink.cdc.runtime.functions.impl
org.apache.flink.cdc.runtime.operators.transform
org.apache.flink.cdc.runtime.operators.transform.async

Uses of AiModelClient in org.apache.flink.cdc.common.model

Methods in org.apache.flink.cdc.common.model that return AiModelClient

Modifier and Type	Method	Description
AiModelClient	AiModelClientFactory.createClient(ModelContext context)	Creates a new AiModelClient from the given context.

Uses of AiModelClient in org.apache.flink.cdc.models.dummy

Classes in org.apache.flink.cdc.models.dummy that implement AiModelClient

Modifier and Type	Class	Description
class	DummyModelClient	Deterministic AI model client used by tests.

Methods in org.apache.flink.cdc.models.dummy that return AiModelClient

Modifier and Type	Method	Description
AiModelClient	DummyModelClientFactory.createClient(ModelContext context)

Uses of AiModelClient in org.apache.flink.cdc.models.openai

Classes in org.apache.flink.cdc.models.openai that implement AiModelClient

Modifier and Type	Class	Description
class	OpenAiCompatibleModelClient	AI model client that connects to an OpenAI-compatible endpoint.

Methods in org.apache.flink.cdc.models.openai that return AiModelClient

Modifier and Type	Method	Description
AiModelClient	OpenAiCompatibleModelClientFactory.createClient(ModelContext context)

Uses of AiModelClient in org.apache.flink.cdc.runtime.functions.impl

Method parameters in org.apache.flink.cdc.runtime.functions.impl with type arguments of type AiModelClient

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

Uses of AiModelClient in org.apache.flink.cdc.runtime.operators.transform

Method parameters in org.apache.flink.cdc.runtime.operators.transform with type arguments of type AiModelClient

Modifier and Type	Method	Description
PostTransformOperatorBuilder	PostTransformOperatorBuilder.addModelClients(Map<String,AiModelClient> clients)
static TransformFilterProcessor	TransformFilterProcessor.of(PostTransformChangeInfo tableInfo, TransformFilter transformFilter, String timezone, DecimalPrecisionMode decimalPrecisionMode, List<UserDefinedFunctionDescriptor> udfDescriptors, List<Object> udfFunctionInstances, SupportedMetadataColumn[] supportedMetadataColumns, Map<String,AiModelClient> modelClients)

Constructor parameters in org.apache.flink.cdc.runtime.operators.transform with type arguments of type AiModelClient

Constructor	Description
TransformProjectionProcessor(PostTransformChangeInfo changeInfo, String projectionExpression, String timezone, DecimalPrecisionMode decimalPrecisionMode, List<UserDefinedFunctionDescriptor> udfDescriptors, List<Object> udfFunctionInstances, SupportedMetadataColumn[] supportedMetadataColumns, Map<String,AiModelClient> modelClients)

Uses of AiModelClient in org.apache.flink.cdc.runtime.operators.transform.async

Method parameters in org.apache.flink.cdc.runtime.operators.transform.async with type arguments of type AiModelClient

Modifier and Type	Method	Description
AsyncPostTransformFunctionBuilder	AsyncPostTransformFunctionBuilder.addModelClients(Map<String,AiModelClient> clients)