Serialized Form

Package com.codedstream.otterstream.inference.exception

Class com.codedstream.otterstream.inference.exception.InferenceException extends Exception implements Serializable

Class com.codedstream.otterstream.inference.exception.ModelLoadException extends Exception implements Serializable

Package com.codedstream.otterstream.inference.function

Class com.codedstream.otterstream.inference.function.AsyncModelInferenceFunction extends org.apache.flink.api.common.functions.AbstractRichFunction implements Serializable

Serialized Fields

engineFactory

Function<InferenceConfig,InferenceEngine<?>> engineFactory

inferenceConfig

InferenceConfig inferenceConfig

Package com.codedstreams.otterstreams.sql.async

Class com.codedstreams.otterstreams.sql.async.AsyncMLInferenceFunction extends Object implements Serializable

Serialized Fields

featureExtractor

Function<T,Map<String,Object>> featureExtractor

modelName

String modelName

resultMapper

Function<InferenceResult,R> resultMapper

Class com.codedstreams.otterstreams.sql.async.AsyncMLPredictFunction extends org.apache.flink.streaming.api.functions.async.RichAsyncFunction<Map<String,Object>,Double> implements Serializable

Serialized Fields

modelName

String modelName

Package com.codedstreams.otterstreams.sql.cep

Class com.codedstreams.otterstreams.sql.cep.PatternInferenceFunction extends org.apache.flink.cep.functions.PatternProcessFunction<T,R> implements Serializable

Serialized Fields

modelName

String modelName

Package com.codedstreams.otterstreams.sql.config

Class com.codedstreams.otterstreams.sql.config.CacheConfig extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

enabled

boolean enabled

maxSize

int maxSize

resultCacheEnabled

boolean resultCacheEnabled

resultCacheMaxSize

int resultCacheMaxSize

resultCacheTtlMs

long resultCacheTtlMs

ttlMs

long ttlMs

Class com.codedstreams.otterstreams.sql.config.EndpointConfig extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

authToken

String authToken

connectionTimeoutMs

long connectionTimeoutMs

headers

Map<String,String> headers

readTimeoutMs

long readTimeoutMs

url

String url

Class com.codedstreams.otterstreams.sql.config.ModelSourceConfig extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

accessKey

String accessKey

AWS/S3 credentials

authToken

String authToken

HTTP authentication

connectionTimeoutMs

long connectionTimeoutMs

Connection timeout for remote sources

headers

Map<String,String> headers

Custom headers for HTTP requests

minioEndpoint

String minioEndpoint

MinIO configuration

modelFormat

ModelFormat modelFormat

Model format

modelPath

String modelPath

Model path/URI

readTimeoutMs

long readTimeoutMs

Read timeout for remote sources

region

String region

secretKey

String secretKey

sourceType

ModelSourceConfig.SourceType sourceType

Source type (derived from path)

Class com.codedstreams.otterstreams.sql.config.SqlInferenceConfig extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

additionalOptions

Map<String,String> additionalOptions

asyncEnabled

boolean asyncEnabled

asyncTimeoutMs

long asyncTimeoutMs

batchSize

int batchSize

batchTimeoutMs

long batchTimeoutMs

cacheConfig

CacheConfig cacheConfig

maxRetries

int maxRetries

modelName

String modelName

modelSource

ModelSourceConfig modelSource

modelVersion

String modelVersion

retryBackoffMs

long retryBackoffMs

Package com.codedstreams.otterstreams.sql.connector

Class com.codedstreams.otterstreams.sql.connector.MLInferenceLookupFunction extends org.apache.flink.table.functions.TableFunction<org.apache.flink.table.data.RowData> implements Serializable

Serialized Fields

config

SqlInferenceConfig config

Package com.codedstreams.otterstreams.sql.metadata

Class com.codedstreams.otterstreams.sql.metadata.InputOutputSchema extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

inputs

List<InputOutputSchema.FieldSchema> inputs

outputs

List<InputOutputSchema.FieldSchema> outputs

Class com.codedstreams.otterstreams.sql.metadata.InputOutputSchema.FieldSchema extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

name

String name

shape

List<Integer> shape

type

String type

Class com.codedstreams.otterstreams.sql.metadata.ModelDescriptor extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

format

ModelFormat format

modelId

String modelId

modelName

String modelName

path

String path

registrationTime

long registrationTime

schema

InputOutputSchema schema

tags

Map<String,String> tags

version

String version

Package com.codedstreams.otterstreams.sql.runtime

Class com.codedstreams.otterstreams.sql.runtime.ModelSession extends Object implements Serializable

serialVersionUID:

1L

Serialized Fields

lastAccessTime

long lastAccessTime

modelId

String modelId

sessionId

String sessionId

Package com.codedstreams.otterstreams.sql.udf

Class com.codedstreams.otterstreams.sql.udf.MLInferenceFunction extends org.apache.flink.table.functions.ScalarFunction implements Serializable

Class com.codedstreams.otterstreams.sql.udf.MLPredictAggregateFunction extends org.apache.flink.table.functions.AggregateFunction<Double,MLPredictAggregateFunction.Accumulator> implements Serializable

Class com.codedstreams.otterstreams.sql.udf.MLPredictScalarFunction extends org.apache.flink.table.functions.ScalarFunction implements Serializable

serialVersionUID:

1L

Class com.codedstreams.otterstreams.sql.udf.MLPredictTableFunction extends org.apache.flink.table.functions.TableFunction<org.apache.flink.types.Row> implements Serializable