A C D E F G H I J M N O P R S T V
All Classes All Packages

A

AbstractOpenAIModelFunction - Class in org.apache.flink.model.openai

Abstract parent class for AsyncPredictFunctions for OpenAI API.

AbstractOpenAIModelFunction(ModelProviderFactory.Context, ReadableConfig) - Constructor for class org.apache.flink.model.openai.AbstractOpenAIModelFunction

AbstractOpenAIModelFunction.ErrorHandlingStrategy - Enum in org.apache.flink.model.openai

Strategy for handling errors during model requests.

AbstractOpenAIModelFunction.ErrorMessageMetadata - Enum in org.apache.flink.model.openai

Metadata that can be read from the output row about error messages.

AbstractOpenAIModelFunction.RetryFallbackStrategy - Enum in org.apache.flink.model.openai

The fallback strategy for when retry attempts are exhausted.

API_KEY - Static variable in class org.apache.flink.model.openai.OpenAIOptions

asyncPredict(RowData) - Method in class org.apache.flink.model.openai.AbstractOpenAIModelFunction

asyncPredictInternal(String) - Method in class org.apache.flink.model.openai.AbstractOpenAIModelFunction

asyncPredictInternal(String) - Method in class org.apache.flink.model.openai.OpenAIChatModelFunction

asyncPredictInternal(String) - Method in class org.apache.flink.model.openai.OpenAIEmbeddingModelFunction

C

client - Variable in class org.apache.flink.model.openai.AbstractOpenAIModelFunction

close() - Method in class org.apache.flink.model.openai.AbstractOpenAIModelFunction

CONTEXT_OVERFLOW_ACTION - Static variable in class org.apache.flink.model.openai.OpenAIOptions

ContextOverflowAction - Enum in org.apache.flink.model.openai

Context overflow action.

copy() - Method in class org.apache.flink.model.openai.OpenAIModelProviderFactory.Provider

createAsyncClient(String, String, int) - Static method in class org.apache.flink.model.openai.OpenAIUtils

createAsyncPredictFunction(ModelProvider.Context) - Method in class org.apache.flink.model.openai.OpenAIModelProviderFactory.Provider

createModelProvider(ModelProviderFactory.Context) - Method in class org.apache.flink.model.openai.OpenAIModelProviderFactory

D

DIMENSION - Static variable in class org.apache.flink.model.openai.OpenAIOptions

E

ENDPOINT - Static variable in class org.apache.flink.model.openai.OpenAIOptions

ENDPOINT_SUFFIX - Static variable in class org.apache.flink.model.openai.OpenAIChatModelFunction

ENDPOINT_SUFFIX - Static variable in class org.apache.flink.model.openai.OpenAIEmbeddingModelFunction

ERROR_HANDLING_STRATEGY - Static variable in class org.apache.flink.model.openai.OpenAIOptions

ERROR_STRING - org.apache.flink.model.openai.AbstractOpenAIModelFunction.ErrorMessageMetadata

F

factoryIdentifier() - Method in class org.apache.flink.model.openai.OpenAIModelProviderFactory

FAILOVER - org.apache.flink.model.openai.AbstractOpenAIModelFunction.ErrorHandlingStrategy

FAILOVER - org.apache.flink.model.openai.AbstractOpenAIModelFunction.RetryFallbackStrategy

G

getAllValuesAndDescriptions() - Static method in enum org.apache.flink.model.openai.ContextOverflowAction

getDescription() - Method in enum org.apache.flink.model.openai.AbstractOpenAIModelFunction.ErrorHandlingStrategy

getDescription() - Method in enum org.apache.flink.model.openai.AbstractOpenAIModelFunction.RetryFallbackStrategy

getDescription() - Method in enum org.apache.flink.model.openai.ContextOverflowAction

getEndpointSuffix() - Method in class org.apache.flink.model.openai.AbstractOpenAIModelFunction

getEndpointSuffix() - Method in class org.apache.flink.model.openai.OpenAIChatModelFunction

getEndpointSuffix() - Method in class org.apache.flink.model.openai.OpenAIEmbeddingModelFunction

getResponseFormat() - Method in enum org.apache.flink.model.openai.OpenAIChatModelFunction.ChatModelResponseFormat

H

handleErrorsAndRespond(Throwable) - Method in class org.apache.flink.model.openai.AbstractOpenAIModelFunction

HTTP_HEADERS_MAP - org.apache.flink.model.openai.AbstractOpenAIModelFunction.ErrorMessageMetadata

HTTP_STATUS_CODE - org.apache.flink.model.openai.AbstractOpenAIModelFunction.ErrorMessageMetadata

I

IDENTIFIER - Static variable in class org.apache.flink.model.openai.OpenAIModelProviderFactory

IGNORE - org.apache.flink.model.openai.AbstractOpenAIModelFunction.ErrorHandlingStrategy

IGNORE - org.apache.flink.model.openai.AbstractOpenAIModelFunction.RetryFallbackStrategy

initializeEncodingForContextLimit(String, Integer) - Method in enum org.apache.flink.model.openai.ContextOverflowAction

Initialize encoding for given model.

J

JSON_OBJECT - org.apache.flink.model.openai.OpenAIChatModelFunction.ChatModelResponseFormat

M

MAX_CONTEXT_SIZE - Static variable in class org.apache.flink.model.openai.OpenAIOptions

MAX_TOKENS - Static variable in class org.apache.flink.model.openai.OpenAIOptions

MODEL - Static variable in class org.apache.flink.model.openai.OpenAIOptions

N

N - Static variable in class org.apache.flink.model.openai.OpenAIOptions

O

open(FunctionContext) - Method in class org.apache.flink.model.openai.AbstractOpenAIModelFunction

OpenAIChatModelFunction - Class in org.apache.flink.model.openai

AsyncPredictFunction for OpenAI chat completion task.

OpenAIChatModelFunction(ModelProviderFactory.Context, ReadableConfig) - Constructor for class org.apache.flink.model.openai.OpenAIChatModelFunction

OpenAIChatModelFunction.ChatModelResponseFormat - Enum in org.apache.flink.model.openai

The response format for Chat model function.

OpenAIEmbeddingModelFunction - Class in org.apache.flink.model.openai

AsyncPredictFunction for OpenAI embedding task.

OpenAIEmbeddingModelFunction(ModelProviderFactory.Context, ReadableConfig) - Constructor for class org.apache.flink.model.openai.OpenAIEmbeddingModelFunction

OpenAIModelProviderFactory - Class in org.apache.flink.model.openai

ModelProviderFactory for OpenAI model functions.

OpenAIModelProviderFactory() - Constructor for class org.apache.flink.model.openai.OpenAIModelProviderFactory

OpenAIModelProviderFactory.Provider - Class in org.apache.flink.model.openai

ModelProvider for openai model functions.

OpenAIOptions - Class in org.apache.flink.model.openai

Options for OpenAI API Model Functions.

OpenAIOptions() - Constructor for class org.apache.flink.model.openai.OpenAIOptions

OpenAIUtils - Class in org.apache.flink.model.openai

Utility class related to Open AI SDK.

OpenAIUtils() - Constructor for class org.apache.flink.model.openai.OpenAIUtils

optionalOptions() - Method in class org.apache.flink.model.openai.OpenAIModelProviderFactory

org.apache.flink.model.openai - package org.apache.flink.model.openai

outputColumnNames - Variable in class org.apache.flink.model.openai.AbstractOpenAIModelFunction

P

PRESENCE_PENALTY - Static variable in class org.apache.flink.model.openai.OpenAIOptions

processTokensWithLimit(String, String, Integer) - Method in enum org.apache.flink.model.openai.ContextOverflowAction

Process tokens with given context limit.

Provider(AsyncPredictFunction) - Constructor for class org.apache.flink.model.openai.OpenAIModelProviderFactory.Provider

R

releaseAsyncClient(String, String) - Static method in class org.apache.flink.model.openai.OpenAIUtils

requiredOptions() - Method in class org.apache.flink.model.openai.OpenAIModelProviderFactory

RESPONSE_FORMAT - Static variable in class org.apache.flink.model.openai.OpenAIOptions

RETRY - org.apache.flink.model.openai.AbstractOpenAIModelFunction.ErrorHandlingStrategy

RETRY_FALLBACK_STRATEGY - Static variable in class org.apache.flink.model.openai.OpenAIOptions

RETRY_NUM - Static variable in class org.apache.flink.model.openai.OpenAIOptions

S

SEED - Static variable in class org.apache.flink.model.openai.OpenAIOptions

SKIPPED - org.apache.flink.model.openai.ContextOverflowAction

SKIPPED_LOG - org.apache.flink.model.openai.ContextOverflowAction

STOP - Static variable in class org.apache.flink.model.openai.OpenAIOptions

STOP_SEPARATOR - Static variable in class org.apache.flink.model.openai.OpenAIChatModelFunction

SYSTEM_PROMPT - Static variable in class org.apache.flink.model.openai.OpenAIOptions

T

TEMPERATURE - Static variable in class org.apache.flink.model.openai.OpenAIOptions

TEXT - org.apache.flink.model.openai.OpenAIChatModelFunction.ChatModelResponseFormat

TOP_P - Static variable in class org.apache.flink.model.openai.OpenAIOptions

toString() - Method in enum org.apache.flink.model.openai.ContextOverflowAction

toString() - Method in enum org.apache.flink.model.openai.OpenAIChatModelFunction.ChatModelResponseFormat

TRUNCATED_HEAD - org.apache.flink.model.openai.ContextOverflowAction

TRUNCATED_HEAD_LOG - org.apache.flink.model.openai.ContextOverflowAction

TRUNCATED_TAIL - org.apache.flink.model.openai.ContextOverflowAction

TRUNCATED_TAIL_LOG - org.apache.flink.model.openai.ContextOverflowAction

V

validateSingleColumnSchema(ResolvedSchema, LogicalType, String) - Method in class org.apache.flink.model.openai.AbstractOpenAIModelFunction

valueOf(String) - Static method in enum org.apache.flink.model.openai.AbstractOpenAIModelFunction.ErrorHandlingStrategy

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.flink.model.openai.AbstractOpenAIModelFunction.ErrorMessageMetadata

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.flink.model.openai.AbstractOpenAIModelFunction.RetryFallbackStrategy

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.flink.model.openai.ContextOverflowAction

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.flink.model.openai.OpenAIChatModelFunction.ChatModelResponseFormat

Returns the enum constant of this type with the specified name.

values() - Static method in enum org.apache.flink.model.openai.AbstractOpenAIModelFunction.ErrorHandlingStrategy

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.flink.model.openai.AbstractOpenAIModelFunction.ErrorMessageMetadata

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.flink.model.openai.AbstractOpenAIModelFunction.RetryFallbackStrategy

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.flink.model.openai.ContextOverflowAction

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.flink.model.openai.OpenAIChatModelFunction.ChatModelResponseFormat

Returns an array containing the constants of this enum type, in the order they are declared.

A C D E F G H I J M N O P R S T V
All Classes All Packages