Package org.apache.flink.cdc.runtime.model

Class OpenAIEmbeddingModel

java.lang.Object

org.apache.flink.cdc.runtime.model.OpenAIEmbeddingModel

All Implemented Interfaces:

UserDefinedFunction

public class OpenAIEmbeddingModel
extends Object
implements UserDefinedFunction

A UserDefinedFunction that use Model defined by OpenAI to generate vector data, refer to docs}.

Constructor Summary

Constructors

Constructor	Description
OpenAIEmbeddingModel()

Method Summary

Modifier and Type	Method	Description
void	close()	This will be invoked before a UDF got destroyed.
ArrayData	eval(String input)
DataType	getReturnType()	Returns the return type of this UDF when it cannot be derived from per-UDF options.
void	open(UserDefinedFunctionContext userDefinedFunctionContext)	This will be invoked every time when a UDF got created.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.cdc.common.udf.UserDefinedFunction

getReturnType, open

Constructor Detail

OpenAIEmbeddingModel

public OpenAIEmbeddingModel()

Method Detail

eval

public ArrayData eval(String input)

getReturnType

public DataType getReturnType()

Description copied from interface: UserDefinedFunction

Returns the return type of this UDF when it cannot be derived from per-UDF options.

Specified by:

getReturnType in interface UserDefinedFunction

open

public void open(UserDefinedFunctionContext userDefinedFunctionContext)

Description copied from interface: UserDefinedFunction

This will be invoked every time when a UDF got created.

Specified by:

open in interface UserDefinedFunction

close

public void close()

Description copied from interface: UserDefinedFunction

This will be invoked before a UDF got destroyed.

Specified by:

close in interface UserDefinedFunction