Index (Otter Streams - ML Inference for Apache Flink 1.0.16 API)

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

A

accumulate(MLPredictAggregateFunction.Accumulator, String) - Method in class com.codedstreams.otterstreams.sql.udf.MLPredictAggregateFunction
Accumulator() - Constructor for class com.codedstreams.otterstreams.sql.udf.MLPredictAggregateFunction.Accumulator
addHeader(String, String) - Method in class com.codedstreams.otterstreams.sql.config.ModelSourceConfig.Builder
additionalOptions(Map<String, String>) - Method in class com.codedstreams.otterstreams.sql.config.SqlInferenceConfig.Builder
addOption(String, String) - Method in class com.codedstreams.otterstreams.sql.config.SqlInferenceConfig.Builder
addVersion(String, ModelDescriptor) - Method in class com.codedstreams.otterstreams.sql.metadata.ModelVersionManager
apiKey(String) - Method in class com.codedstream.otterstream.inference.config.AuthConfig.Builder: Sets the API key.
applyThreshold(double, double) - Static method in class com.codedstreams.otterstreams.sql.util.ResultPostprocessor: Applies threshold to binary classification.
asSummaryString() - Method in class com.codedstreams.otterstreams.sql.connector.MLInferenceDynamicTableSource
asyncEnabled(boolean) - Method in class com.codedstreams.otterstreams.sql.config.SqlInferenceConfig.Builder
AsyncInferenceExecutor - Class in com.codedstreams.otterstreams.sql.async: AsyncInferenceExecutor provides a simple abstraction for executing tasks asynchronously using a fixed-size thread pool.
AsyncInferenceExecutor(int) - Constructor for class com.codedstreams.otterstreams.sql.async.AsyncInferenceExecutor: Creates a new AsyncInferenceExecutor with a fixed-size thread pool.
asyncInvoke(IN, ResultFuture<OUT>) - Method in class com.codedstream.otterstream.inference.function.AsyncModelInferenceFunction: Performs asynchronous inference on input record.
asyncInvoke(Map<String, Object>, ResultFuture<Double>) - Method in class com.codedstreams.otterstreams.sql.async.AsyncMLPredictFunction
asyncInvoke(T, ResultFuture<R>) - Method in class com.codedstreams.otterstreams.sql.async.AsyncMLInferenceFunction
AsyncMLInferenceFunction<T,R> - Class in com.codedstreams.otterstreams.sql.async: Asynchronous ML inference function for Flink streams.
AsyncMLInferenceFunction(String, Function<T, Map<String, Object>>, Function<InferenceResult, R>) - Constructor for class com.codedstreams.otterstreams.sql.async.AsyncMLInferenceFunction
AsyncMLPredictFunction - Class in com.codedstreams.otterstreams.sql.async: Async function for non-blocking inference.
AsyncMLPredictFunction(String) - Constructor for class com.codedstreams.otterstreams.sql.async.AsyncMLPredictFunction
AsyncModelInferenceFunction<IN,OUT> - Class in com.codedstream.otterstream.inference.function: Asynchronous function for performing ML inference in Apache Flink streams.
AsyncModelInferenceFunction(InferenceConfig, Function<InferenceConfig, InferenceEngine<?>>) - Constructor for class com.codedstream.otterstream.inference.function.AsyncModelInferenceFunction: Constructs async inference function.
AsyncResultHandler<T> - Class in com.codedstreams.otterstreams.sql.async: Handles async inference results.
AsyncResultHandler() - Constructor for class com.codedstreams.otterstreams.sql.async.AsyncResultHandler
asyncTimeout(Duration) - Method in class com.codedstreams.otterstreams.sql.config.SqlInferenceConfig.Builder
asyncTimeoutMs(long) - Method in class com.codedstreams.otterstreams.sql.config.SqlInferenceConfig.Builder
authConfig(AuthConfig) - Method in class com.codedstream.otterstream.inference.config.ModelConfig.Builder
AuthConfig - Class in com.codedstream.otterstream.inference.config: Configuration for authentication with remote ML inference endpoints.
AuthConfig(String, String, Map<String, String>) - Constructor for class com.codedstream.otterstream.inference.config.AuthConfig: Constructs authentication configuration.
AuthConfig.Builder - Class in com.codedstream.otterstream.inference.config: Builder for creating AuthConfig instances.
authToken(String) - Method in class com.codedstreams.otterstreams.sql.config.EndpointConfig.Builder
authToken(String) - Method in class com.codedstreams.otterstreams.sql.config.ModelSourceConfig.Builder
AZURE_ML - com.codedstream.otterstream.inference.model.ModelFormat: Azure Machine Learning service

B

BatchInferenceProcessor - Class in com.codedstreams.otterstreams.sql.runtime: Batches inference requests for improved throughput.
BatchInferenceProcessor(InferenceEngine<?>, int, long) - Constructor for class com.codedstreams.otterstreams.sql.runtime.BatchInferenceProcessor
batchSize(int) - Method in class com.codedstream.otterstream.inference.config.InferenceConfig.Builder: Sets the batch size for inference operations.
batchSize(int) - Method in class com.codedstreams.otterstreams.sql.config.SqlInferenceConfig.Builder
batchTimeout(Duration) - Method in class com.codedstreams.otterstreams.sql.config.SqlInferenceConfig.Builder
batchTimeoutMs(long) - Method in class com.codedstreams.otterstreams.sql.config.SqlInferenceConfig.Builder
build() - Method in class com.codedstream.otterstream.inference.config.AuthConfig.Builder: Builds the AuthConfig instance.
build() - Method in class com.codedstream.otterstream.inference.config.InferenceConfig.Builder: Builds the InferenceConfig instance.
build() - Method in class com.codedstream.otterstream.inference.config.ModelConfig.Builder: Builds the ModelConfig instance.
build() - Method in class com.codedstream.otterstream.inference.model.ModelMetadata.Builder: Builds a new ModelMetadata instance.
build() - Method in class com.codedstreams.otterstreams.sql.config.CacheConfig.Builder
build() - Method in class com.codedstreams.otterstreams.sql.config.EndpointConfig.Builder
build() - Method in class com.codedstreams.otterstreams.sql.config.ModelSourceConfig.Builder
build() - Method in class com.codedstreams.otterstreams.sql.config.SqlInferenceConfig.Builder
buildConfigurationError(String, String) - Static method in class com.codedstreams.otterstreams.sql.util.InferenceErrorBuilder
builder() - Static method in class com.codedstream.otterstream.inference.config.AuthConfig: Creates a new builder for AuthConfig.
builder() - Static method in class com.codedstream.otterstream.inference.config.InferenceConfig: Creates a new builder for InferenceConfig.
builder() - Static method in class com.codedstream.otterstream.inference.config.ModelConfig: Creates a new builder for ModelConfig.
builder() - Static method in class com.codedstream.otterstream.inference.model.ModelMetadata: Creates a new Builder instance for constructing ModelMetadata.
builder() - Static method in class com.codedstreams.otterstreams.sql.config.CacheConfig
builder() - Static method in class com.codedstreams.otterstreams.sql.config.EndpointConfig
builder() - Static method in class com.codedstreams.otterstreams.sql.config.ModelSourceConfig
builder() - Static method in class com.codedstreams.otterstreams.sql.config.SqlInferenceConfig: Builder for SqlInferenceConfig with sensible defaults.
Builder() - Constructor for class com.codedstream.otterstream.inference.config.AuthConfig.Builder
Builder() - Constructor for class com.codedstream.otterstream.inference.config.InferenceConfig.Builder
Builder() - Constructor for class com.codedstream.otterstream.inference.config.ModelConfig.Builder
Builder() - Constructor for class com.codedstream.otterstream.inference.model.ModelMetadata.Builder
Builder() - Constructor for class com.codedstreams.otterstreams.sql.config.CacheConfig.Builder
Builder() - Constructor for class com.codedstreams.otterstreams.sql.config.EndpointConfig.Builder
Builder() - Constructor for class com.codedstreams.otterstreams.sql.config.ModelSourceConfig.Builder
Builder() - Constructor for class com.codedstreams.otterstreams.sql.config.SqlInferenceConfig.Builder
buildFeatureExtractionError(String, Exception) - Static method in class com.codedstreams.otterstreams.sql.util.InferenceErrorBuilder
buildInferenceTimeoutError(String, long) - Static method in class com.codedstreams.otterstreams.sql.util.InferenceErrorBuilder
buildModelNotFoundError(String) - Static method in class com.codedstreams.otterstreams.sql.util.InferenceErrorBuilder

C

cacheConfig(CacheConfig) - Method in class com.codedstreams.otterstreams.sql.config.SqlInferenceConfig.Builder
CacheConfig - Class in com.codedstreams.otterstreams.sql.config: Configuration for model and result caching in SQL inference.
CacheConfig.Builder - Class in com.codedstreams.otterstreams.sql.config
cacheEnabled(boolean) - Method in class com.codedstreams.otterstreams.sql.config.SqlInferenceConfig.Builder
cacheMaxSize(int) - Method in class com.codedstreams.otterstreams.sql.config.SqlInferenceConfig.Builder
CacheStrategy - Enum in com.codedstream.otterstream.inference.cache: Defines caching strategies for ML inference operations in Otter Stream.
cacheTtl(Duration) - Method in class com.codedstreams.otterstreams.sql.config.SqlInferenceConfig.Builder
CEPInferenceIntegration - Class in com.codedstreams.otterstreams.sql.cep: Integration between Flink CEP and ML inference for pattern-based decisions.
CEPInferenceIntegration() - Constructor for class com.codedstreams.otterstreams.sql.cep.CEPInferenceIntegration
close() - Method in interface com.codedstream.otterstream.inference.engine.InferenceEngine: Closes the inference engine and releases all resources.
close() - Method in class com.codedstream.otterstream.inference.engine.LocalInferenceEngine
close() - Method in class com.codedstream.otterstream.onnx.InferenceSession: Closes the session and releases native resources.
close() - Method in class com.codedstream.otterstream.onnx.OnnxInferenceEngine: Closes the engine and releases all native resources.
close() - Method in class com.codedstream.otterstream.pmml.PmmlInferenceEngine: Closes the PMML inference engine and releases resources.
close() - Method in class com.codedstream.otterstream.pytorch.TorchScriptInferenceEngine: Closes the engine and releases all DJL and native resources.
close() - Method in class com.codedstream.otterstream.remote.http.HttpInferenceClient: Closes the HTTP client and releases resources.
close() - Method in class com.codedstream.otterstream.remote.RemoteInferenceEngine: Closes the engine and releases resources.
close() - Method in class com.codedstream.otterstream.remote.sagemaker.SageMakerInferenceClient: Closes the SageMaker client and releases AWS resources.
close() - Method in class com.codedstream.otterstream.remote.vertex.VertexAIInferenceClient: Closes the Vertex AI client and releases Google Cloud resources.
close() - Method in class com.codedstream.otterstream.tensorflow.TensorFlowInferenceEngine: Closes the TensorFlow engine and releases native resources.
close() - Method in class com.codedstream.otterstream.xgboost.XGBoostInferenceEngine: Closes the XGBoost engine and releases native resources.
close() - Method in class com.codedstreams.otterstreams.sql.async.AsyncMLPredictFunction
close() - Method in interface com.codedstreams.otterstreams.sql.loader.ModelSource: Closes any resources associated with this source.
close() - Method in class com.codedstreams.otterstreams.sql.runtime.TensorFlowGraphDefEngine
close() - Method in class com.codedstreams.otterstreams.sql.runtime.TensorFlowSavedModelEngine
close() - Method in class com.codedstreams.otterstreams.sql.udf.MLPredictScalarFunction
CLOSED - com.codedstreams.otterstreams.sql.runtime.InferenceCircuitBreaker.State
com.codedstream.otterstream.inference.cache - package com.codedstream.otterstream.inference.cache
com.codedstream.otterstream.inference.config - package com.codedstream.otterstream.inference.config
com.codedstream.otterstream.inference.engine - package com.codedstream.otterstream.inference.engine
com.codedstream.otterstream.inference.exception - package com.codedstream.otterstream.inference.exception
com.codedstream.otterstream.inference.function - package com.codedstream.otterstream.inference.function
com.codedstream.otterstream.inference.metrics - package com.codedstream.otterstream.inference.metrics
com.codedstream.otterstream.inference.model - package com.codedstream.otterstream.inference.model
com.codedstream.otterstream.onnx - package com.codedstream.otterstream.onnx
com.codedstream.otterstream.pmml - package com.codedstream.otterstream.pmml
com.codedstream.otterstream.pytorch - package com.codedstream.otterstream.pytorch
com.codedstream.otterstream.remote - package com.codedstream.otterstream.remote
com.codedstream.otterstream.remote.http - package com.codedstream.otterstream.remote.http
com.codedstream.otterstream.remote.sagemaker - package com.codedstream.otterstream.remote.sagemaker
com.codedstream.otterstream.remote.vertex - package com.codedstream.otterstream.remote.vertex
com.codedstream.otterstream.tensorflow - package com.codedstream.otterstream.tensorflow
com.codedstream.otterstream.xgboost - package com.codedstream.otterstream.xgboost
com.codedstreams.otterstream.examples - package com.codedstreams.otterstream.examples
com.codedstreams.otterstreams.sql - package com.codedstreams.otterstreams.sql
com.codedstreams.otterstreams.sql.async - package com.codedstreams.otterstreams.sql.async
com.codedstreams.otterstreams.sql.cep - package com.codedstreams.otterstreams.sql.cep
com.codedstreams.otterstreams.sql.config - package com.codedstreams.otterstreams.sql.config
com.codedstreams.otterstreams.sql.connector - package com.codedstreams.otterstreams.sql.connector
com.codedstreams.otterstreams.sql.loader - package com.codedstreams.otterstreams.sql.loader
com.codedstreams.otterstreams.sql.metadata - package com.codedstreams.otterstreams.sql.metadata
com.codedstreams.otterstreams.sql.rules - package com.codedstreams.otterstreams.sql.rules
com.codedstreams.otterstreams.sql.runtime - package com.codedstreams.otterstreams.sql.runtime
com.codedstreams.otterstreams.sql.udf - package com.codedstreams.otterstreams.sql.udf
com.codedstreams.otterstreams.sql.util - package com.codedstreams.otterstreams.sql.util
complete(boolean) - Method in class com.codedstreams.otterstreams.sql.loader.ModelLoadingProgressTracker.LoadingProgress
completeLoading(String, boolean) - Method in class com.codedstreams.otterstreams.sql.loader.ModelLoadingProgressTracker
ConfigurationValidator - Class in com.codedstreams.otterstreams.sql.config: Validates SQL inference configurations.
ConfigurationValidator() - Constructor for class com.codedstreams.otterstreams.sql.config.ConfigurationValidator
ConfigurationValidator.ValidationResult - Class in com.codedstreams.otterstreams.sql.config: Result of configuration validation.
connectionTimeoutMs(long) - Method in class com.codedstreams.otterstreams.sql.config.EndpointConfig.Builder
connectionTimeoutMs(long) - Method in class com.codedstreams.otterstreams.sql.config.ModelSourceConfig.Builder
CONNECTOR_IDENTIFIER - Static variable in class com.codedstreams.otterstreams.sql.OtterStreamSQLConstants
convertToJavaType(Object, Class<?>) - Static method in class com.codedstreams.otterstreams.sql.util.TypeUtils
copy() - Method in class com.codedstreams.otterstreams.sql.connector.MLInferenceDynamicTableSource
count - Variable in class com.codedstreams.otterstreams.sql.udf.MLPredictAggregateFunction.Accumulator
create(ModelSourceConfig) - Static method in class com.codedstreams.otterstreams.sql.loader.ModelLoaderFactory
createAccumulator() - Method in class com.codedstreams.otterstreams.sql.udf.MLPredictAggregateFunction
createDynamicTableSource(DynamicTableFactory.Context) - Method in class com.codedstreams.otterstreams.sql.connector.MLInferenceDynamicTableFactory
createEngine(ModelConfig) - Static method in class com.codedstreams.otterstreams.sql.runtime.InferenceEngineFactory
createFunctionDefinition(String, CatalogFunction, FunctionDefinitionFactory.Context) - Method in class com.codedstreams.otterstreams.sql.udf.MLInferenceFunctionFactory
credentials(String, String) - Method in class com.codedstreams.otterstreams.sql.config.ModelSourceConfig.Builder

D

DDLParserHelper - Class in com.codedstreams.otterstreams.sql.util: Helper for parsing SQL DDL options.
DDLParserHelper() - Constructor for class com.codedstreams.otterstreams.sql.util.DDLParserHelper
DecisionEngine<T> - Interface in com.codedstreams.otterstreams.sql.rules: Generic decision engine abstraction.
DEFAULT_ASYNC_TIMEOUT_MS - Static variable in class com.codedstreams.otterstreams.sql.OtterStreamSQLConstants
DEFAULT_BATCH_SIZE - Static variable in class com.codedstreams.otterstreams.sql.OtterStreamSQLConstants
DEFAULT_BATCH_TIMEOUT_MS - Static variable in class com.codedstreams.otterstreams.sql.OtterStreamSQLConstants
DEFAULT_CACHE_SIZE - Static variable in class com.codedstreams.otterstreams.sql.OtterStreamSQLConstants
DEFAULT_CACHE_TTL_MINUTES - Static variable in class com.codedstreams.otterstreams.sql.OtterStreamSQLConstants
DEFAULT_MAX_RETRIES - Static variable in class com.codedstreams.otterstreams.sql.OtterStreamSQLConstants
DEFAULT_RETRY_BACKOFF_MS - Static variable in class com.codedstreams.otterstreams.sql.OtterStreamSQLConstants
denormalize(double, double, double) - Static method in class com.codedstreams.otterstreams.sql.util.ResultPostprocessor: Denormalizes predictions back to original scale.
deserialize(byte[]) - Static method in class com.codedstreams.otterstreams.sql.util.SerializationUtils
DroolsDecisionEngine - Class in com.codedstreams.otterstreams.sql.rules: Stateless Drools-based decision engine.
DroolsDecisionEngine(StatelessKieSession) - Constructor for class com.codedstreams.otterstreams.sql.rules.DroolsDecisionEngine

E

enabled(boolean) - Method in class com.codedstreams.otterstreams.sql.config.CacheConfig.Builder
enableMetrics(boolean) - Method in class com.codedstream.otterstream.inference.config.InferenceConfig.Builder: Enables or disables metrics collection.
EndpointConfig - Class in com.codedstreams.otterstreams.sql.config
EndpointConfig.Builder - Class in com.codedstreams.otterstreams.sql.config
endpointUrl - Variable in class com.codedstream.otterstream.remote.RemoteInferenceEngine
endpointUrl(String) - Method in class com.codedstream.otterstream.inference.config.ModelConfig.Builder
EngineCapabilities(boolean, boolean, int, boolean) - Constructor for class com.codedstream.otterstream.inference.engine.InferenceEngine.EngineCapabilities: Constructs engine capabilities.
engineOptions(Map<String, Object>) - Method in class com.codedstream.otterstream.inference.config.InferenceConfig.Builder: Sets engine-specific options.
equals(Object) - Method in class com.codedstream.otterstream.inference.model.ModelMetadata: Compares this metadata to another object for equality.
eval(Object...) - Method in class com.codedstreams.otterstreams.sql.connector.MLInferenceLookupFunction
eval(String, String) - Method in class com.codedstreams.otterstreams.sql.udf.MLPredictScalarFunction
eval(String, String) - Method in class com.codedstreams.otterstreams.sql.udf.MLPredictTableFunction
eval(Map<String, Object>, String) - Method in class com.codedstreams.otterstreams.sql.udf.MLInferenceFunction
evaluate(Object) - Method in class com.codedstreams.otterstreams.sql.rules.DroolsDecisionEngine
evaluate(T) - Method in interface com.codedstreams.otterstreams.sql.rules.DecisionEngine: Evaluates the input against configured rules.
execute(Supplier<T>) - Method in class com.codedstreams.otterstreams.sql.runtime.InferenceCircuitBreaker: Attempts to execute operation through circuit breaker.
executeWithRetry(Supplier<T>, String) - Method in class com.codedstreams.otterstreams.sql.runtime.InferenceRetryHandler: Executes operation with retry logic.
extractFeatures(IN) - Method in class com.codedstream.otterstream.inference.function.AsyncModelInferenceFunction: Extracts model input features from the input record.
extractFeatures(String) - Static method in class com.codedstreams.otterstreams.sql.util.JsonFeatureExtractor
extractSchema(InferenceEngine<?>) - Static method in class com.codedstreams.otterstreams.sql.metadata.InputOutputSchemaExtractor: Extracts schema from inference engine.

F

factoryIdentifier() - Method in class com.codedstreams.otterstreams.sql.connector.MLInferenceDynamicTableFactory
factoryIdentifier() - Method in class com.codedstreams.otterstreams.sql.udf.MLInferenceFunctionFactory
FEATURE_BASED - com.codedstream.otterstream.inference.cache.CacheStrategy: Cache based on specific feature values - granular caching control
FeaturePreprocessor - Class in com.codedstreams.otterstreams.sql.util: Preprocesses features before inference (normalization, encoding, etc.).
FeaturePreprocessor() - Constructor for class com.codedstreams.otterstreams.sql.util.FeaturePreprocessor
features - Variable in class com.codedstreams.otterstreams.sql.udf.MLPredictAggregateFunction.Accumulator
FieldSchema(String, String, List<Integer>) - Constructor for class com.codedstreams.otterstreams.sql.metadata.InputOutputSchema.FieldSchema
fillMissingValues(Map<String, Object>, Map<String, Object>) - Static method in class com.codedstreams.otterstreams.sql.util.FeaturePreprocessor: Fills missing values with defaults.
format(ModelFormat) - Method in class com.codedstream.otterstream.inference.config.ModelConfig.Builder
format(ModelFormat) - Method in class com.codedstream.otterstream.inference.model.ModelMetadata.Builder: Sets the model format.
FORMAT_ONNX - Static variable in class com.codedstreams.otterstreams.sql.OtterStreamSQLConstants
FORMAT_PYTORCH - Static variable in class com.codedstreams.otterstreams.sql.OtterStreamSQLConstants
FORMAT_TENSORFLOW_GRAPHDEF - Static variable in class com.codedstreams.otterstreams.sql.OtterStreamSQLConstants
FORMAT_TENSORFLOW_SAVEDMODEL - Static variable in class com.codedstreams.otterstreams.sql.OtterStreamSQLConstants
FORMAT_XGBOOST - Static variable in class com.codedstreams.otterstreams.sql.OtterStreamSQLConstants
FraudDetectionExample - Class in com.codedstreams.otterstream.examples: Example demonstrating real-time fraud detection using OtterStream's ML inference capabilities.
FraudDetectionExample() - Constructor for class com.codedstreams.otterstream.examples.FraudDetectionExample
fromOptions(Map<String, String>) - Static method in class com.codedstreams.otterstreams.sql.config.SqlInferenceConfig: Creates configuration from SQL DDL options.
fromTensor(Tensor) - Static method in class com.codedstreams.otterstreams.sql.util.TensorConverter: Converts a TensorFlow tensor to a Java object.
FUNCTION_ML_PREDICT - Static variable in class com.codedstreams.otterstreams.sql.OtterStreamSQLConstants
FUNCTION_ML_PREDICT_AGG - Static variable in class com.codedstreams.otterstreams.sql.OtterStreamSQLConstants
FUNCTION_ML_PREDICT_ASYNC - Static variable in class com.codedstreams.otterstreams.sql.OtterStreamSQLConstants
FUNCTION_ML_PREDICT_TABLE - Static variable in class com.codedstreams.otterstreams.sql.OtterStreamSQLConstants
FunctionRegistrationHelper - Class in com.codedstreams.otterstreams.sql.udf: Helper class for registering SQL functions programmatically.
FunctionRegistrationHelper() - Constructor for class com.codedstreams.otterstreams.sql.udf.FunctionRegistrationHelper

G

get() - Static method in class com.codedstreams.otterstreams.sql.udf.RuleEngineProvider: Returns a lazily initialized decision engine.
get(String) - Method in class com.codedstreams.otterstreams.sql.runtime.InferenceContext
get(K) - Method in class com.codedstream.otterstream.inference.cache.ModelCache: Retrieves a cached value if present.
getAccessKey() - Method in class com.codedstreams.otterstreams.sql.config.ModelSourceConfig
getAdditionalOptions() - Method in class com.codedstreams.otterstreams.sql.config.SqlInferenceConfig
getApiKey() - Method in class com.codedstream.otterstream.inference.config.AuthConfig: Gets the API key.
getAsyncTimeoutMs() - Method in class com.codedstreams.otterstreams.sql.config.SqlInferenceConfig
getAuthConfig() - Method in class com.codedstream.otterstream.inference.config.ModelConfig
getAuthToken() - Method in class com.codedstreams.otterstreams.sql.config.EndpointConfig
getAuthToken() - Method in class com.codedstreams.otterstreams.sql.config.ModelSourceConfig
getAverageLatencyMs() - Method in class com.codedstreams.otterstreams.sql.runtime.InferenceMetricsCollector.ModelMetrics
getBatchSize() - Method in class com.codedstream.otterstream.inference.config.InferenceConfig
getBatchSize() - Method in class com.codedstreams.otterstreams.sql.config.SqlInferenceConfig
getBatchTimeoutMs() - Method in class com.codedstreams.otterstreams.sql.config.SqlInferenceConfig
getCacheConfig() - Method in class com.codedstreams.otterstreams.sql.config.SqlInferenceConfig
getCachedInputNames() - Method in class com.codedstream.otterstream.tensorflow.TensorFlowInferenceEngine: Gets the cached input tensor names.
getCachedOutputNames() - Method in class com.codedstream.otterstream.tensorflow.TensorFlowInferenceEngine: Gets the cached output tensor names.
getCacheHitRate() - Method in class com.codedstreams.otterstreams.sql.runtime.InferenceMetricsCollector.ModelMetrics
getCacheHits() - Method in class com.codedstreams.otterstreams.sql.runtime.InferenceMetricsCollector.ModelMetrics
getCacheMisses() - Method in class com.codedstreams.otterstreams.sql.runtime.InferenceMetricsCollector.ModelMetrics
getCapabilities() - Method in interface com.codedstream.otterstream.inference.engine.InferenceEngine: Gets the capabilities of this inference engine.
getCapabilities() - Method in class com.codedstream.otterstream.inference.engine.LocalInferenceEngine
getCapabilities() - Method in class com.codedstream.otterstream.onnx.OnnxInferenceEngine: Gets the engine's capabilities.
getCapabilities() - Method in class com.codedstream.otterstream.pmml.PmmlInferenceEngine: Gets the engine's capabilities for PMML inference.
getCapabilities() - Method in class com.codedstream.otterstream.pytorch.TorchScriptInferenceEngine: Gets the engine's capabilities for PyTorch inference.
getCapabilities() - Method in class com.codedstream.otterstream.remote.RemoteInferenceEngine: Gets engine capabilities for remote endpoints.
getCapabilities() - Method in class com.codedstream.otterstream.remote.vertex.VertexAIInferenceClient: Gets the engine's capabilities for Vertex AI inference.
getCapabilities() - Method in class com.codedstream.otterstream.tensorflow.TensorFlowInferenceEngine: Gets the engine's capabilities for TensorFlow inference.
getCapabilities() - Method in class com.codedstream.otterstream.xgboost.XGBoostInferenceEngine: Gets the engine's capabilities for XGBoost inference.
getCapabilities() - Method in class com.codedstreams.otterstreams.sql.runtime.TensorFlowGraphDefEngine
getCapabilities() - Method in class com.codedstreams.otterstreams.sql.runtime.TensorFlowSavedModelEngine
getChangelogMode() - Method in class com.codedstreams.otterstreams.sql.connector.MLInferenceDynamicTableSource
getConnectionTimeoutMs() - Method in class com.codedstreams.otterstreams.sql.config.EndpointConfig
getConnectionTimeoutMs() - Method in class com.codedstreams.otterstreams.sql.config.ModelSourceConfig
getConsecutiveFailures() - Method in class com.codedstreams.otterstreams.sql.runtime.ModelHealthChecker.HealthStatus
getCurrentStage() - Method in class com.codedstreams.otterstreams.sql.loader.ModelLoadingProgressTracker.LoadingProgress
getDescription() - Method in enum com.codedstream.otterstream.inference.cache.CacheStrategy: Gets the human-readable description of this caching strategy.
getDescription() - Method in enum com.codedstream.otterstream.inference.model.ModelFormat: Gets the human-readable description.
getElapsedTime() - Method in class com.codedstreams.otterstreams.sql.loader.ModelLoadingContext
getElapsedTime() - Method in class com.codedstreams.otterstreams.sql.loader.ModelLoadingProgressTracker.LoadingProgress
getElapsedTime() - Method in class com.codedstreams.otterstreams.sql.runtime.InferenceContext
getEndpointUrl() - Method in class com.codedstream.otterstream.inference.config.ModelConfig
getEngine() - Method in class com.codedstreams.otterstreams.sql.runtime.ModelHealthChecker.HealthStatus
getEngine(String) - Method in class com.codedstreams.otterstreams.sql.loader.ModelCache
getEngineOptions() - Method in class com.codedstream.otterstream.inference.config.InferenceConfig
getErrorMessage() - Method in class com.codedstream.otterstream.inference.model.InferenceResult: Gets error message for failed inferences.
getErrors() - Method in class com.codedstreams.otterstreams.sql.config.ConfigurationValidator.ValidationResult
getExtension() - Method in enum com.codedstream.otterstream.inference.model.ModelFormat: Gets the file extension for this model format.
getFailedInferences() - Method in class com.codedstreams.otterstreams.sql.runtime.InferenceMetricsCollector.ModelMetrics
getFailureCount() - Method in class com.codedstreams.otterstreams.sql.runtime.InferenceCircuitBreaker
getFormat() - Method in class com.codedstream.otterstream.inference.config.ModelConfig
getFormat() - Method in class com.codedstream.otterstream.inference.model.ModelMetadata: Gets the format of the model.
getFormat() - Method in class com.codedstreams.otterstreams.sql.metadata.ModelDescriptor
getHeaders() - Method in class com.codedstream.otterstream.inference.config.AuthConfig: Gets custom authentication headers.
getHeaders() - Method in class com.codedstreams.otterstreams.sql.config.EndpointConfig
getHeaders() - Method in class com.codedstreams.otterstreams.sql.config.ModelSourceConfig
getHealthStatus(String) - Method in class com.codedstreams.otterstreams.sql.runtime.ModelHealthChecker
getHttpClient() - Method in class com.codedstreams.otterstreams.sql.loader.ModelServerConnectionPool
getInferenceTimeMs() - Method in class com.codedstream.otterstream.inference.model.InferenceResult: Gets inference duration.
getInputMetadata() - Method in class com.codedstream.otterstream.onnx.InferenceSession: Gets metadata about model inputs.
getInputs() - Method in class com.codedstreams.otterstreams.sql.metadata.InputOutputSchema
getInputSchema() - Method in class com.codedstream.otterstream.inference.model.ModelMetadata: Gets the input schema describing model inputs.
getInstance() - Static method in class com.codedstreams.otterstreams.sql.loader.ModelCache
getInstance() - Static method in class com.codedstreams.otterstreams.sql.loader.ModelLoadingProgressTracker
getInstance() - Static method in class com.codedstreams.otterstreams.sql.loader.ModelRegistrationManager
getInstance() - Static method in class com.codedstreams.otterstreams.sql.loader.ModelServerConnectionPool
getInstance() - Static method in class com.codedstreams.otterstreams.sql.metadata.ModelRegistry
getInstance() - Static method in class com.codedstreams.otterstreams.sql.runtime.InferenceMetricsCollector
getInstance() - Static method in class com.codedstreams.otterstreams.sql.runtime.ModelHealthChecker
getLastAccessTime() - Method in class com.codedstreams.otterstreams.sql.runtime.ModelSession
getLastCheckTime() - Method in class com.codedstreams.otterstreams.sql.runtime.ModelHealthChecker.HealthStatus
getLatest() - Method in class com.codedstreams.otterstreams.sql.metadata.ModelVersionManager
getLoadTimestamp() - Method in class com.codedstream.otterstream.inference.model.ModelMetadata: Gets the timestamp when the model was loaded.
getLocation() - Method in interface com.codedstreams.otterstreams.sql.loader.ModelSource: Gets the source location/URI.
getLookupRuntimeProvider(LookupTableSource.LookupContext) - Method in class com.codedstreams.otterstreams.sql.connector.MLInferenceDynamicTableSource
getMaxBatchSize() - Method in class com.codedstream.otterstream.inference.engine.InferenceEngine.EngineCapabilities
getMaxLatencyMs() - Method in class com.codedstreams.otterstreams.sql.runtime.InferenceMetricsCollector.ModelMetrics
getMaxRetries() - Method in class com.codedstream.otterstream.inference.config.InferenceConfig
getMaxRetries() - Method in class com.codedstreams.otterstreams.sql.config.SqlInferenceConfig
getMaxSize() - Method in class com.codedstreams.otterstreams.sql.config.CacheConfig
getMetadata() - Method in interface com.codedstream.otterstream.inference.engine.InferenceEngine: Gets metadata about the loaded model.
getMetadata() - Method in class com.codedstream.otterstream.onnx.OnnxInferenceEngine: Gets metadata about the loaded model.
getMetadata() - Method in class com.codedstream.otterstream.pmml.PmmlInferenceEngine: Gets metadata about the loaded PMML model.
getMetadata() - Method in class com.codedstream.otterstream.pytorch.TorchScriptInferenceEngine: Gets metadata about the loaded PyTorch model.
getMetadata() - Method in class com.codedstream.otterstream.remote.http.HttpInferenceClient: Gets metadata about the remote model.
getMetadata() - Method in class com.codedstream.otterstream.remote.sagemaker.SageMakerInferenceClient: Gets metadata about the SageMaker model.
getMetadata() - Method in class com.codedstream.otterstream.remote.vertex.VertexAIInferenceClient: Gets metadata about the Vertex AI model.
getMetadata() - Method in class com.codedstream.otterstream.tensorflow.TensorFlowInferenceEngine: Gets metadata about the loaded TensorFlow model.
getMetadata() - Method in class com.codedstream.otterstream.xgboost.XGBoostInferenceEngine: Gets metadata about the loaded XGBoost model.
getMetadata() - Method in class com.codedstreams.otterstreams.sql.runtime.TensorFlowGraphDefEngine
getMetadata() - Method in class com.codedstreams.otterstreams.sql.runtime.TensorFlowSavedModelEngine
getMetadata(String) - Method in class com.codedstreams.otterstreams.sql.loader.ModelLoadingContext
getMeterRegistry() - Method in class com.codedstream.otterstream.inference.metrics.MetricsCollector: Gets the underlying meter registry.
getMetrics(String) - Method in class com.codedstream.otterstream.inference.metrics.MetricsCollector: Gets or creates metrics instance for a specific model.
getMetrics(String) - Method in class com.codedstreams.otterstreams.sql.runtime.InferenceMetricsCollector
getMinioEndpoint() - Method in class com.codedstreams.otterstreams.sql.config.ModelSourceConfig
getMinLatencyMs() - Method in class com.codedstreams.otterstreams.sql.runtime.InferenceMetricsCollector.ModelMetrics
getModel(String) - Method in class com.codedstreams.otterstreams.sql.metadata.ModelRegistry
getModel(String, String) - Method in class com.codedstreams.otterstreams.sql.metadata.ModelRegistry
getModelConfig() - Method in class com.codedstream.otterstream.inference.config.InferenceConfig
getModelConfig() - Method in interface com.codedstream.otterstream.inference.engine.InferenceEngine: Gets the configuration used to initialize this engine.
getModelConfig() - Method in class com.codedstream.otterstream.inference.engine.LocalInferenceEngine
getModelConfig() - Method in class com.codedstream.otterstream.remote.http.HttpInferenceClient: Gets the model configuration.
getModelConfig() - Method in class com.codedstream.otterstream.remote.sagemaker.SageMakerInferenceClient: Gets the model configuration.
getModelConfig() - Method in class com.codedstream.otterstream.remote.vertex.VertexAIInferenceClient: Gets the model configuration.
getModelFormat() - Method in class com.codedstreams.otterstreams.sql.config.ModelSourceConfig
getModelId() - Method in class com.codedstream.otterstream.inference.config.ModelConfig
getModelId() - Method in class com.codedstream.otterstream.inference.model.InferenceResult: Gets model identifier.
getModelId() - Method in class com.codedstreams.otterstreams.sql.metadata.ModelDescriptor
getModelId() - Method in class com.codedstreams.otterstreams.sql.runtime.ModelSession
getModelMetadata(InferenceSession) - Method in class com.codedstream.otterstream.onnx.OnnxModelLoader: Extracts metadata from a loaded ONNX model.
getModelMetadata(T) - Method in interface com.codedstream.otterstream.inference.model.ModelLoader: Extracts metadata from a loaded model.
getModelName() - Method in class com.codedstream.otterstream.inference.config.ModelConfig
getModelName() - Method in class com.codedstream.otterstream.inference.model.ModelMetadata: Gets the name of the model.
getModelName() - Method in class com.codedstreams.otterstreams.sql.config.SqlInferenceConfig
getModelName() - Method in class com.codedstreams.otterstreams.sql.loader.ModelLoadingContext
getModelName() - Method in class com.codedstreams.otterstreams.sql.loader.ModelLoadingProgressTracker.LoadingProgress
getModelName() - Method in class com.codedstreams.otterstreams.sql.metadata.ModelDescriptor
getModelName() - Method in class com.codedstreams.otterstreams.sql.metadata.ModelVersionManager
getModelName() - Method in class com.codedstreams.otterstreams.sql.runtime.ModelHealthChecker.HealthStatus
getModelOptions() - Method in class com.codedstream.otterstream.inference.config.ModelConfig
getModelPath() - Method in class com.codedstream.otterstream.inference.config.ModelConfig
getModelPath() - Method in class com.codedstreams.otterstreams.sql.config.ModelSourceConfig
getModelPath() - Method in class com.codedstreams.otterstreams.sql.loader.HttpModelLoader
getModelPath() - Method in class com.codedstreams.otterstreams.sql.loader.LocalModelLoader
getModelPath() - Method in class com.codedstreams.otterstreams.sql.loader.MinioModelLoader
getModelPath() - Method in interface com.codedstreams.otterstreams.sql.loader.ModelLoader
getModelPath() - Method in class com.codedstreams.otterstreams.sql.loader.S3ModelLoader
getModelSize() - Method in class com.codedstream.otterstream.inference.model.ModelMetadata: Gets the size of the model in bytes.
getModelSource() - Method in class com.codedstreams.otterstreams.sql.config.SqlInferenceConfig
getModelVersion() - Method in class com.codedstream.otterstream.inference.config.ModelConfig
getModelVersion() - Method in class com.codedstream.otterstream.inference.model.ModelMetadata: Gets the version of the model.
getModelVersion() - Method in class com.codedstreams.otterstreams.sql.config.SqlInferenceConfig
getName() - Method in class com.codedstreams.otterstreams.sql.metadata.InputOutputSchema.FieldSchema
getOutput(String) - Method in class com.codedstream.otterstream.inference.model.InferenceResult: Gets a specific output value by name.
getOutputMetadata() - Method in class com.codedstream.otterstream.onnx.InferenceSession: Gets metadata about model outputs.
getOutputs() - Method in class com.codedstream.otterstream.inference.model.InferenceResult: Gets all output predictions.
getOutputs() - Method in class com.codedstreams.otterstreams.sql.metadata.InputOutputSchema
getOutputSchema() - Method in class com.codedstream.otterstream.inference.model.ModelMetadata: Gets the output schema describing model outputs.
getPath() - Method in class com.codedstreams.otterstreams.sql.metadata.ModelDescriptor
getPercentComplete() - Method in class com.codedstreams.otterstreams.sql.loader.ModelLoadingProgressTracker.LoadingProgress
getProgress(String) - Method in class com.codedstreams.otterstreams.sql.loader.ModelLoadingProgressTracker
getReadTimeoutMs() - Method in class com.codedstreams.otterstreams.sql.config.EndpointConfig
getReadTimeoutMs() - Method in class com.codedstreams.otterstreams.sql.config.ModelSourceConfig
getRegion() - Method in class com.codedstreams.otterstreams.sql.config.ModelSourceConfig
getRegistrationTime() - Method in class com.codedstreams.otterstreams.sql.metadata.ModelDescriptor
getRequestTime() - Method in class com.codedstreams.otterstreams.sql.runtime.InferenceContext
getResultCacheMaxSize() - Method in class com.codedstreams.otterstreams.sql.config.CacheConfig
getResultCacheTtlMs() - Method in class com.codedstreams.otterstreams.sql.config.CacheConfig
getRetryBackoffMs() - Method in class com.codedstreams.otterstreams.sql.config.SqlInferenceConfig
getSchema() - Method in class com.codedstreams.otterstreams.sql.metadata.ModelDescriptor
getSecretKey() - Method in class com.codedstreams.otterstreams.sql.config.ModelSourceConfig
getSession() - Method in class com.codedstream.otterstream.onnx.InferenceSession: Gets the underlying ONNX Runtime session.
getSessionId() - Method in class com.codedstreams.otterstreams.sql.runtime.ModelSession
getShape() - Method in class com.codedstreams.otterstreams.sql.metadata.InputOutputSchema.FieldSchema
getSize() - Method in interface com.codedstreams.otterstreams.sql.loader.ModelSource: Gets the size of the model in bytes if available.
getSourceConfig() - Method in class com.codedstreams.otterstreams.sql.loader.ModelLoadingContext
getSourceType() - Method in class com.codedstreams.otterstreams.sql.config.ModelSourceConfig
getState() - Method in class com.codedstreams.otterstreams.sql.runtime.InferenceCircuitBreaker
getSuccessfulInferences() - Method in class com.codedstreams.otterstreams.sql.runtime.InferenceMetricsCollector.ModelMetrics
getSuccessRate() - Method in class com.codedstreams.otterstreams.sql.runtime.InferenceMetricsCollector.ModelMetrics
getSupportedFormats() - Method in interface com.codedstream.otterstream.inference.model.ModelLoader: Gets the model formats supported by this loader.
getSupportedFormats() - Method in class com.codedstream.otterstream.onnx.OnnxModelLoader: Gets the model formats supported by this loader.
getTags() - Method in class com.codedstreams.otterstreams.sql.metadata.ModelDescriptor
getTimeoutMs() - Method in class com.codedstream.otterstream.inference.config.InferenceConfig
getToken() - Method in class com.codedstream.otterstream.inference.config.AuthConfig: Gets the bearer token.
getTotalInferences() - Method in class com.codedstreams.otterstreams.sql.runtime.InferenceMetricsCollector.ModelMetrics
getTtlMs() - Method in class com.codedstreams.otterstreams.sql.config.CacheConfig
getType() - Method in class com.codedstreams.otterstreams.sql.metadata.InputOutputSchema.FieldSchema
getUrl() - Method in class com.codedstreams.otterstreams.sql.config.EndpointConfig
getValue(MLPredictAggregateFunction.Accumulator) - Method in class com.codedstreams.otterstreams.sql.udf.MLPredictAggregateFunction
getVersion() - Method in class com.codedstreams.otterstreams.sql.metadata.ModelDescriptor
getVersion(String) - Method in class com.codedstreams.otterstreams.sql.metadata.ModelVersionManager
getWarnings() - Method in class com.codedstreams.otterstreams.sql.config.ConfigurationValidator.ValidationResult

H

HALF_OPEN - com.codedstreams.otterstreams.sql.runtime.InferenceCircuitBreaker.State
handleFailure(ResultFuture<T>, Throwable) - Method in class com.codedstreams.otterstreams.sql.async.AsyncResultHandler
handleFeedback(String, Object, Object) - Method in class com.codedstreams.otterstreams.sql.cep.ReinforcementHandler
handleSuccess(ResultFuture<T>, T) - Method in class com.codedstreams.otterstreams.sql.async.AsyncResultHandler
handleTimeout(ResultFuture<T>) - Method in class com.codedstreams.otterstreams.sql.async.AsyncResultHandler
hasAuthentication() - Method in class com.codedstreams.otterstreams.sql.config.ModelSourceConfig: Checks if authentication is configured.
hashCode() - Method in class com.codedstream.otterstream.inference.model.ModelMetadata: Returns a hash code based on all metadata fields.
HDFS - com.codedstreams.otterstreams.sql.config.ModelSourceConfig.SourceType
headers(Map<String, String>) - Method in class com.codedstream.otterstream.inference.config.AuthConfig.Builder: Sets custom authentication headers.
headers(Map<String, String>) - Method in class com.codedstreams.otterstreams.sql.config.EndpointConfig.Builder
headers(Map<String, String>) - Method in class com.codedstreams.otterstreams.sql.config.ModelSourceConfig.Builder
HealthStatus(String, InferenceEngine<?>) - Constructor for class com.codedstreams.otterstreams.sql.runtime.ModelHealthChecker.HealthStatus
HTTP - com.codedstreams.otterstreams.sql.config.ModelSourceConfig.SourceType
HttpInferenceClient - Class in com.codedstream.otterstream.remote.http: HTTP-based remote inference client for REST API model endpoints.
HttpInferenceClient() - Constructor for class com.codedstream.otterstream.remote.http.HttpInferenceClient
HttpModelLoader - Class in com.codedstreams.otterstreams.sql.loader: Loads models from HTTP/HTTPS endpoints.
HttpModelLoader(ModelSourceConfig) - Constructor for class com.codedstreams.otterstreams.sql.loader.HttpModelLoader

I

IDENTIFIER - Static variable in class com.codedstreams.otterstreams.sql.connector.MLInferenceDynamicTableFactory
infer(Map<String, Object>) - Method in interface com.codedstream.otterstream.inference.engine.InferenceEngine: Performs inference on a single input.
infer(Map<String, Object>) - Method in class com.codedstream.otterstream.inference.engine.LocalInferenceEngine
infer(Map<String, Object>) - Method in class com.codedstream.otterstream.onnx.OnnxInferenceEngine: Performs single inference on the provided inputs.
infer(Map<String, Object>) - Method in class com.codedstream.otterstream.pmml.PmmlInferenceEngine: Performs single inference on the provided inputs using the PMML model.
infer(Map<String, Object>) - Method in class com.codedstream.otterstream.pytorch.TorchScriptInferenceEngine: Performs single inference on the provided inputs using the PyTorch model.
infer(Map<String, Object>) - Method in class com.codedstream.otterstream.remote.http.HttpInferenceClient: Sends inference request to remote HTTP endpoint.
infer(Map<String, Object>) - Method in class com.codedstream.otterstream.remote.RemoteInferenceEngine: Performs single inference on remote endpoint (abstract).
infer(Map<String, Object>) - Method in class com.codedstream.otterstream.remote.sagemaker.SageMakerInferenceClient: Invokes SageMaker endpoint for inference.
infer(Map<String, Object>) - Method in class com.codedstream.otterstream.remote.vertex.VertexAIInferenceClient: Performs single inference using Vertex AI PredictionService.
infer(Map<String, Object>) - Method in class com.codedstream.otterstream.tensorflow.TensorFlowInferenceEngine: Performs single inference using TensorFlow SavedModel.
infer(Map<String, Object>) - Method in class com.codedstream.otterstream.xgboost.XGBoostInferenceEngine: Performs single inference using XGBoost model.
infer(Map<String, Object>) - Method in class com.codedstreams.otterstreams.sql.runtime.TensorFlowGraphDefEngine
infer(Map<String, Object>) - Method in class com.codedstreams.otterstreams.sql.runtime.TensorFlowSavedModelEngine
inferBatch(Map<String, Object>[]) - Method in interface com.codedstream.otterstream.inference.engine.InferenceEngine: Performs batch inference on multiple inputs.
inferBatch(Map<String, Object>[]) - Method in class com.codedstream.otterstream.inference.engine.LocalInferenceEngine
inferBatch(Map<String, Object>[]) - Method in class com.codedstream.otterstream.onnx.OnnxInferenceEngine: Performs batch inference on multiple input sets.
inferBatch(Map<String, Object>[]) - Method in class com.codedstream.otterstream.pmml.PmmlInferenceEngine: Performs batch inference by sequentially processing multiple input sets.
inferBatch(Map<String, Object>[]) - Method in class com.codedstream.otterstream.pytorch.TorchScriptInferenceEngine: Batch inference implementation.
inferBatch(Map<String, Object>[]) - Method in class com.codedstream.otterstream.remote.RemoteInferenceEngine: Performs batch inference using sequential processing.
inferBatch(Map<String, Object>[]) - Method in class com.codedstream.otterstream.remote.vertex.VertexAIInferenceClient: Performs batch inference using Vertex AI native batch support.
inferBatch(Map<String, Object>[]) - Method in class com.codedstream.otterstream.tensorflow.TensorFlowInferenceEngine: Performs batch inference (simplified implementation).
inferBatch(Map<String, Object>[]) - Method in class com.codedstream.otterstream.xgboost.XGBoostInferenceEngine: Performs batch inference using XGBoost's efficient matrix operations.
inferBatch(Map<String, Object>[]) - Method in class com.codedstreams.otterstreams.sql.runtime.TensorFlowGraphDefEngine
inferBatch(Map<String, Object>[]) - Method in class com.codedstreams.otterstreams.sql.runtime.TensorFlowSavedModelEngine: Performs batch inference by running each input separately.
InferenceCircuitBreaker - Class in com.codedstreams.otterstreams.sql.runtime: Circuit breaker to prevent cascading failures in inference operations.
InferenceCircuitBreaker(String, int, long) - Constructor for class com.codedstreams.otterstreams.sql.runtime.InferenceCircuitBreaker
InferenceCircuitBreaker.State - Enum in com.codedstreams.otterstreams.sql.runtime
InferenceConfig - Class in com.codedstream.otterstream.inference.config: Comprehensive configuration for ML inference operations in Apache Flink streams.
InferenceConfig(ModelConfig, int, long, int, boolean, Map<String, Object>) - Constructor for class com.codedstream.otterstream.inference.config.InferenceConfig: Constructs inference configuration.
InferenceConfig.Builder - Class in com.codedstream.otterstream.inference.config: Builder for creating InferenceConfig instances with sensible defaults.
InferenceContext - Class in com.codedstreams.otterstreams.sql.runtime: Context for inference execution with metadata.
InferenceContext() - Constructor for class com.codedstreams.otterstreams.sql.runtime.InferenceContext
InferenceEngine<T> - Interface in com.codedstream.otterstream.inference.engine: Core interface for ML inference engines in Otter Stream.
InferenceEngine.EngineCapabilities - Class in com.codedstream.otterstream.inference.engine: Describes the capabilities of an inference engine.
InferenceEngineFactory - Class in com.codedstreams.otterstreams.sql.runtime: Factory for creating inference engines based on model format.
InferenceEngineFactory() - Constructor for class com.codedstreams.otterstreams.sql.runtime.InferenceEngineFactory
InferenceErrorBuilder - Class in com.codedstreams.otterstreams.sql.util: Builder for user-friendly error messages.
InferenceErrorBuilder() - Constructor for class com.codedstreams.otterstreams.sql.util.InferenceErrorBuilder
InferenceException - Exception in com.codedstream.otterstream.inference.exception: Exception thrown when inference operations fail.
InferenceException(String) - Constructor for exception com.codedstream.otterstream.inference.exception.InferenceException: Constructs an inference exception with a message.
InferenceException(String, Throwable) - Constructor for exception com.codedstream.otterstream.inference.exception.InferenceException: Constructs an inference exception with a message and cause.
InferenceMetrics - Class in com.codedstream.otterstream.inference.metrics: Collects and records metrics for ML inference operations.
InferenceMetrics(MeterRegistry, String) - Constructor for class com.codedstream.otterstream.inference.metrics.InferenceMetrics: Constructs inference metrics collector.
InferenceMetricsCollector - Class in com.codedstreams.otterstreams.sql.runtime: Collects and tracks inference metrics per model.
InferenceMetricsCollector.ModelMetrics - Class in com.codedstreams.otterstreams.sql.runtime: Metrics for a single model.
InferenceResult - Class in com.codedstream.otterstream.inference.model: Container for ML inference results including predictions and metadata.
InferenceResult(String, String, long) - Constructor for class com.codedstream.otterstream.inference.model.InferenceResult: Creates a failed inference result.
InferenceResult(Map<String, Object>, long, String) - Constructor for class com.codedstream.otterstream.inference.model.InferenceResult: Creates a successful inference result.
InferenceRetryHandler - Class in com.codedstreams.otterstreams.sql.runtime: Handles retry logic for failed inference operations.
InferenceRetryHandler(int, long, double) - Constructor for class com.codedstreams.otterstreams.sql.runtime.InferenceRetryHandler
InferenceSession - Class in com.codedstream.otterstream.onnx: Wrapper class for ONNX Runtime sessions providing simplified access to inference capabilities.
InferenceSession(byte[], OrtSession.SessionOptions, OrtEnvironment) - Constructor for class com.codedstream.otterstream.onnx.InferenceSession: Loads an ONNX model from a byte array.
InferenceSession(String, OrtSession.SessionOptions, OrtEnvironment) - Constructor for class com.codedstream.otterstream.onnx.InferenceSession: Loads an ONNX model from a file path.
initialize(ModelConfig) - Method in interface com.codedstream.otterstream.inference.engine.InferenceEngine: Initializes the inference engine with the given configuration.
initialize(ModelConfig) - Method in class com.codedstream.otterstream.inference.engine.LocalInferenceEngine
initialize(ModelConfig) - Method in class com.codedstream.otterstream.onnx.OnnxInferenceEngine: Initializes the ONNX inference engine with the provided configuration.
initialize(ModelConfig) - Method in class com.codedstream.otterstream.pmml.PmmlInferenceEngine: Initializes the PMML inference engine by loading and parsing a PMML model file.
initialize(ModelConfig) - Method in class com.codedstream.otterstream.pytorch.TorchScriptInferenceEngine: Initializes the PyTorch inference engine by loading a TorchScript model.
initialize(ModelConfig) - Method in class com.codedstream.otterstream.remote.http.HttpInferenceClient: Initializes the HTTP inference client with connection configuration.
initialize(ModelConfig) - Method in class com.codedstream.otterstream.remote.RemoteInferenceEngine: Initializes the remote inference engine with endpoint configuration.
initialize(ModelConfig) - Method in class com.codedstream.otterstream.remote.sagemaker.SageMakerInferenceClient: Initializes the SageMaker inference client with AWS configuration.
initialize(ModelConfig) - Method in class com.codedstream.otterstream.remote.vertex.VertexAIInferenceClient: Initializes the Vertex AI inference client with Google Cloud configuration.
initialize(ModelConfig) - Method in class com.codedstream.otterstream.tensorflow.TensorFlowInferenceEngine: Initializes the TensorFlow inference engine by loading a SavedModel.
initialize(ModelConfig) - Method in class com.codedstream.otterstream.xgboost.XGBoostInferenceEngine: Initializes the XGBoost inference engine by loading a model file.
initialized - Variable in class com.codedstream.otterstream.inference.engine.LocalInferenceEngine
initialized - Variable in class com.codedstream.otterstream.remote.RemoteInferenceEngine
initializeEngine() - Method in class com.codedstream.otterstream.inference.function.AsyncModelInferenceFunction: Initializes the inference engine lazily.
INPUT_HASH - com.codedstream.otterstream.inference.cache.CacheStrategy: Cache based on hash of input features - best for identical inputs
InputOutputSchema - Class in com.codedstreams.otterstreams.sql.metadata: Schema definition for model inputs and outputs.
InputOutputSchema(List<InputOutputSchema.FieldSchema>, List<InputOutputSchema.FieldSchema>) - Constructor for class com.codedstreams.otterstreams.sql.metadata.InputOutputSchema
InputOutputSchema.FieldSchema - Class in com.codedstreams.otterstreams.sql.metadata
InputOutputSchemaExtractor - Class in com.codedstreams.otterstreams.sql.metadata: Extracts input/output schema from loaded models.
InputOutputSchemaExtractor() - Constructor for class com.codedstreams.otterstreams.sql.metadata.InputOutputSchemaExtractor
inputSchema(Map<String, Object>) - Method in class com.codedstream.otterstream.inference.model.ModelMetadata.Builder: Sets the input schema.
invalidate(String) - Method in class com.codedstreams.otterstreams.sql.loader.ModelCache
invalidate(K) - Method in class com.codedstream.otterstream.inference.cache.ModelCache: Removes a specific entry from the cache.
invalidateAll() - Method in class com.codedstream.otterstream.inference.cache.ModelCache: Clears all entries from the cache.
invalidateAll() - Method in class com.codedstreams.otterstreams.sql.loader.ModelCache
isAccessible() - Method in interface com.codedstreams.otterstreams.sql.loader.ModelSource: Checks if the model source is accessible.
isAsyncEnabled() - Method in class com.codedstreams.otterstreams.sql.config.SqlInferenceConfig
isCompleted() - Method in class com.codedstreams.otterstreams.sql.loader.ModelLoadingProgressTracker.LoadingProgress
isEnabled() - Method in class com.codedstreams.otterstreams.sql.config.CacheConfig
isEnableMetrics() - Method in class com.codedstream.otterstream.inference.config.InferenceConfig
isHealthy() - Method in class com.codedstreams.otterstreams.sql.runtime.ModelHealthChecker.HealthStatus
isReady() - Method in interface com.codedstream.otterstream.inference.engine.InferenceEngine: Checks if the engine is ready for inference operations.
isReady() - Method in class com.codedstream.otterstream.inference.engine.LocalInferenceEngine
isReady() - Method in class com.codedstream.otterstream.remote.RemoteInferenceEngine: Checks if the engine is ready for inference.
isReady() - Method in class com.codedstream.otterstream.remote.vertex.VertexAIInferenceClient: Checks if the engine is ready for inference.
isRemote() - Method in class com.codedstream.otterstream.inference.config.ModelConfig: Checks if this is a remote model configuration.
isResultCacheEnabled() - Method in class com.codedstreams.otterstreams.sql.config.CacheConfig
isRetryable(Exception) - Static method in class com.codedstreams.otterstreams.sql.runtime.InferenceRetryHandler: Checks if exception is retryable.
isSuccess() - Method in class com.codedstream.otterstream.inference.model.InferenceResult: Checks if inference was successful.
isSuccess() - Method in class com.codedstreams.otterstreams.sql.loader.ModelLoadingProgressTracker.LoadingProgress
isTriggered() - Method in class com.codedstreams.otterstreams.sql.rules.RuleOutcome
isValid() - Method in class com.codedstreams.otterstreams.sql.config.ConfigurationValidator.ValidationResult
isValidOptionKey(String) - Static method in class com.codedstreams.otterstreams.sql.util.DDLParserHelper: Validates option key format.

J

javaToFlinkType(Class<?>) - Static method in class com.codedstreams.otterstreams.sql.util.TypeUtils
JsonFeatureExtractor - Class in com.codedstreams.otterstreams.sql.util: Extracts features from JSON strings for model input.
JsonFeatureExtractor() - Constructor for class com.codedstreams.otterstreams.sql.util.JsonFeatureExtractor

L

loadedModel - Variable in class com.codedstream.otterstream.inference.engine.LocalInferenceEngine
LoadingProgress(String) - Constructor for class com.codedstreams.otterstreams.sql.loader.ModelLoadingProgressTracker.LoadingProgress
loadModel() - Method in class com.codedstreams.otterstreams.sql.loader.HttpModelLoader
loadModel() - Method in class com.codedstreams.otterstreams.sql.loader.LocalModelLoader
loadModel() - Method in class com.codedstreams.otterstreams.sql.loader.MinioModelLoader
loadModel() - Method in interface com.codedstreams.otterstreams.sql.loader.ModelLoader
loadModel() - Method in class com.codedstreams.otterstreams.sql.loader.S3ModelLoader
loadModel(ModelConfig) - Method in interface com.codedstream.otterstream.inference.model.ModelLoader: Loads a model from the path specified in configuration.
loadModel(ModelConfig) - Method in class com.codedstream.otterstream.onnx.OnnxModelLoader: Loads an ONNX model from the path specified in configuration.
loadModel(InputStream, ModelConfig) - Method in interface com.codedstream.otterstream.inference.model.ModelLoader: Loads a model from an input stream.
loadModel(InputStream, ModelConfig) - Method in class com.codedstream.otterstream.onnx.OnnxModelLoader: Loads an ONNX model from an input stream.
loadModelDirectly(ModelConfig) - Method in class com.codedstream.otterstream.inference.engine.LocalInferenceEngine: Override this method for engines that handle their own model loading.
loadModelDirectly(ModelConfig) - Method in class com.codedstreams.otterstreams.sql.runtime.TensorFlowGraphDefEngine
loadModelDirectly(ModelConfig) - Method in class com.codedstreams.otterstreams.sql.runtime.TensorFlowSavedModelEngine
loadTimestamp(long) - Method in class com.codedstream.otterstream.inference.model.ModelMetadata.Builder: Sets the load timestamp.
LOCAL - com.codedstreams.otterstreams.sql.config.ModelSourceConfig.SourceType
LocalInferenceEngine<T> - Class in com.codedstream.otterstream.inference.engine: Abstract base class for local inference engines that load models from files.
LocalInferenceEngine() - Constructor for class com.codedstream.otterstream.inference.engine.LocalInferenceEngine
LocalModelLoader - Class in com.codedstreams.otterstreams.sql.loader: Loads models from local filesystem or HDFS.
LocalModelLoader(ModelSourceConfig) - Constructor for class com.codedstreams.otterstreams.sql.loader.LocalModelLoader
logResults(Logger) - Method in class com.codedstreams.otterstreams.sql.config.ConfigurationValidator.ValidationResult

M

main(String[]) - Static method in class com.codedstreams.otterstream.examples.FraudDetectionExample: Main entry point for the fraud detection pipeline.
maxRetries(int) - Method in class com.codedstream.otterstream.inference.config.InferenceConfig.Builder: Sets maximum retry attempts for failed inferences.
maxRetries(int) - Method in class com.codedstreams.otterstreams.sql.config.SqlInferenceConfig.Builder
maxSize(int) - Method in class com.codedstreams.otterstreams.sql.config.CacheConfig.Builder
METRIC_CACHE_HITS - Static variable in class com.codedstreams.otterstreams.sql.OtterStreamSQLConstants
METRIC_CACHE_MISSES - Static variable in class com.codedstreams.otterstreams.sql.OtterStreamSQLConstants
METRIC_FAILURES_TOTAL - Static variable in class com.codedstreams.otterstreams.sql.OtterStreamSQLConstants
METRIC_LATENCY_MS - Static variable in class com.codedstreams.otterstreams.sql.OtterStreamSQLConstants
METRIC_REQUESTS_TOTAL - Static variable in class com.codedstreams.otterstreams.sql.OtterStreamSQLConstants
METRIC_SUCCESS_TOTAL - Static variable in class com.codedstreams.otterstreams.sql.OtterStreamSQLConstants
MetricsCollector - Class in com.codedstream.otterstream.inference.metrics: Central collector managing metrics for multiple models.
MetricsCollector() - Constructor for class com.codedstream.otterstream.inference.metrics.MetricsCollector: Creates collector with default SimpleMeterRegistry.
MetricsCollector(MeterRegistry) - Constructor for class com.codedstream.otterstream.inference.metrics.MetricsCollector: Creates collector with custom meter registry.
MINIO - com.codedstreams.otterstreams.sql.config.ModelSourceConfig.SourceType
minioEndpoint(String) - Method in class com.codedstreams.otterstreams.sql.config.ModelSourceConfig.Builder
MinioModelLoader - Class in com.codedstreams.otterstreams.sql.loader: Loads models from MinIO object storage.
MinioModelLoader(ModelSourceConfig) - Constructor for class com.codedstreams.otterstreams.sql.loader.MinioModelLoader
MLInferenceDynamicTableFactory - Class in com.codedstreams.otterstreams.sql.connector: Factory for creating ML inference table sources.
MLInferenceDynamicTableFactory() - Constructor for class com.codedstreams.otterstreams.sql.connector.MLInferenceDynamicTableFactory
MLInferenceDynamicTableSource - Class in com.codedstreams.otterstreams.sql.connector: Dynamic table source for ML inference with lookup support.
MLInferenceDynamicTableSource(SqlInferenceConfig, DataType) - Constructor for class com.codedstreams.otterstreams.sql.connector.MLInferenceDynamicTableSource
MLInferenceFunction - Class in com.codedstreams.otterstreams.sql.udf: Flink SQL scalar function for ML inference.
MLInferenceFunction() - Constructor for class com.codedstreams.otterstreams.sql.udf.MLInferenceFunction
MLInferenceFunctionFactory - Class in com.codedstreams.otterstreams.sql.udf
MLInferenceFunctionFactory() - Constructor for class com.codedstreams.otterstreams.sql.udf.MLInferenceFunctionFactory
MLInferenceLookupFunction - Class in com.codedstreams.otterstreams.sql.connector: Lookup function for temporal joins with ML predictions.
MLInferenceLookupFunction(SqlInferenceConfig) - Constructor for class com.codedstreams.otterstreams.sql.connector.MLInferenceLookupFunction
MLPredictAggregateFunction - Class in com.codedstreams.otterstreams.sql.udf: Aggregate function for batch inference over windows.
MLPredictAggregateFunction() - Constructor for class com.codedstreams.otterstreams.sql.udf.MLPredictAggregateFunction
MLPredictAggregateFunction.Accumulator - Class in com.codedstreams.otterstreams.sql.udf
MLPredictScalarFunction - Class in com.codedstreams.otterstreams.sql.udf: Flink SQL Scalar Function for ML model inference.
MLPredictScalarFunction() - Constructor for class com.codedstreams.otterstreams.sql.udf.MLPredictScalarFunction
MLPredictTableFunction - Class in com.codedstreams.otterstreams.sql.udf: Table function that returns multiple rows.
MLPredictTableFunction() - Constructor for class com.codedstreams.otterstreams.sql.udf.MLPredictTableFunction
MODEL_OUTPUT - com.codedstream.otterstream.inference.cache.CacheStrategy: Cache model outputs for reuse - useful for frequently accessed predictions
ModelCache<K,V> - Class in com.codedstream.otterstream.inference.cache: Thread-safe LRU cache for storing ML model predictions and inference results.
ModelCache - Class in com.codedstreams.otterstreams.sql.loader: Thread-safe LRU cache for loaded inference engines.
ModelCache(long, long) - Constructor for class com.codedstream.otterstream.inference.cache.ModelCache: Creates a new model cache with specified size and expiration policy.
modelConfig - Variable in class com.codedstream.otterstream.inference.engine.LocalInferenceEngine
modelConfig - Variable in class com.codedstream.otterstream.remote.RemoteInferenceEngine
modelConfig(ModelConfig) - Method in class com.codedstream.otterstream.inference.config.InferenceConfig.Builder: Sets the model configuration.
ModelConfig - Class in com.codedstream.otterstream.inference.config: Configuration for ML models in Otter Stream inference framework.
ModelConfig(String, String, ModelFormat, String, String, Map<String, Object>, String, AuthConfig) - Constructor for class com.codedstream.otterstream.inference.config.ModelConfig: Constructs model configuration.
ModelConfig.Builder - Class in com.codedstream.otterstream.inference.config: Builder for creating ModelConfig instances.
ModelDescriptor - Class in com.codedstreams.otterstreams.sql.metadata: Metadata descriptor for a registered model.
ModelDescriptor(String, String, String, ModelFormat, String, InputOutputSchema, Map<String, String>) - Constructor for class com.codedstreams.otterstreams.sql.metadata.ModelDescriptor
modelFormat(ModelFormat) - Method in class com.codedstreams.otterstreams.sql.config.ModelSourceConfig.Builder
modelFormat(ModelFormat) - Method in class com.codedstreams.otterstreams.sql.config.SqlInferenceConfig.Builder
ModelFormat - Enum in com.codedstream.otterstream.inference.model: Enumeration of supported ML model formats in Otter Stream.
ModelHealthChecker - Class in com.codedstreams.otterstreams.sql.runtime: Performs periodic health checks on loaded models.
ModelHealthChecker.HealthStatus - Class in com.codedstreams.otterstreams.sql.runtime: Health status for a single model.
modelId(String) - Method in class com.codedstream.otterstream.inference.config.ModelConfig.Builder
modelLoader - Variable in class com.codedstream.otterstream.inference.engine.LocalInferenceEngine
ModelLoader<T> - Interface in com.codedstream.otterstream.inference.model: Interface for loading ML models from various sources.
ModelLoader - Interface in com.codedstreams.otterstreams.sql.loader
ModelLoaderFactory - Class in com.codedstreams.otterstreams.sql.loader: Factory for creating appropriate model loaders based on source type.
ModelLoaderFactory() - Constructor for class com.codedstreams.otterstreams.sql.loader.ModelLoaderFactory
ModelLoadException - Exception in com.codedstream.otterstream.inference.exception: Exception thrown when model loading fails.
ModelLoadException(String) - Constructor for exception com.codedstream.otterstream.inference.exception.ModelLoadException: Constructs a model load exception with a message.
ModelLoadException(String, Throwable) - Constructor for exception com.codedstream.otterstream.inference.exception.ModelLoadException: Constructs a model load exception with a message and cause.
ModelLoadingContext - Class in com.codedstreams.otterstreams.sql.loader: Context information for model loading operations.
ModelLoadingContext(String, ModelSourceConfig) - Constructor for class com.codedstreams.otterstreams.sql.loader.ModelLoadingContext
ModelLoadingProgressTracker - Class in com.codedstreams.otterstreams.sql.loader: Tracks progress of model loading operations.
ModelLoadingProgressTracker.LoadingProgress - Class in com.codedstreams.otterstreams.sql.loader: Represents loading progress for a single model.
ModelMetadata - Class in com.codedstream.otterstream.inference.model: Immutable metadata container for machine learning models.
ModelMetadata(String, String, ModelFormat, Map<String, Object>, Map<String, Object>, long, long) - Constructor for class com.codedstream.otterstream.inference.model.ModelMetadata: Constructs a new ModelMetadata instance with the specified attributes.
ModelMetadata.Builder - Class in com.codedstream.otterstream.inference.model: Builder for constructing ModelMetadata instances.
ModelMetrics() - Constructor for class com.codedstreams.otterstreams.sql.runtime.InferenceMetricsCollector.ModelMetrics
modelName(String) - Method in class com.codedstream.otterstream.inference.config.ModelConfig.Builder
modelName(String) - Method in class com.codedstream.otterstream.inference.model.ModelMetadata.Builder: Sets the model name.
modelName(String) - Method in class com.codedstreams.otterstreams.sql.config.SqlInferenceConfig.Builder
modelOptions(Map<String, Object>) - Method in class com.codedstream.otterstream.inference.config.ModelConfig.Builder
modelPath(String) - Method in class com.codedstream.otterstream.inference.config.ModelConfig.Builder
modelPath(String) - Method in class com.codedstreams.otterstreams.sql.config.ModelSourceConfig.Builder
modelPath(String) - Method in class com.codedstreams.otterstreams.sql.config.SqlInferenceConfig.Builder
ModelRegistrationManager - Class in com.codedstreams.otterstreams.sql.loader: Manages model registration, loading, and lifecycle.
ModelRegistry - Class in com.codedstreams.otterstreams.sql.metadata: Central registry for model metadata and lifecycle management.
ModelServerConnectionPool - Class in com.codedstreams.otterstreams.sql.loader: Manages HTTP connection pooling for remote model servers.
ModelSession - Class in com.codedstreams.otterstreams.sql.runtime: Manages stateful inference sessions.
ModelSession(String, String) - Constructor for class com.codedstreams.otterstreams.sql.runtime.ModelSession
modelSize(long) - Method in class com.codedstream.otterstream.inference.model.ModelMetadata.Builder: Sets the model size in bytes.
modelSource(ModelSourceConfig) - Method in class com.codedstreams.otterstreams.sql.config.SqlInferenceConfig.Builder
ModelSource - Interface in com.codedstreams.otterstreams.sql.loader: Interface for different model source implementations.
ModelSourceConfig - Class in com.codedstreams.otterstreams.sql.config: Configuration for model source locations and loading strategies.
ModelSourceConfig.Builder - Class in com.codedstreams.otterstreams.sql.config
ModelSourceConfig.SourceType - Enum in com.codedstreams.otterstreams.sql.config: Enumeration of supported source types.
modelVersion(String) - Method in class com.codedstream.otterstream.inference.config.ModelConfig.Builder
modelVersion(String) - Method in class com.codedstream.otterstream.inference.model.ModelMetadata.Builder: Sets the model version.
modelVersion(String) - Method in class com.codedstreams.otterstreams.sql.config.SqlInferenceConfig.Builder
ModelVersionManager - Class in com.codedstreams.otterstreams.sql.metadata: Manages multiple versions of a model.
ModelVersionManager(String) - Constructor for class com.codedstreams.otterstreams.sql.metadata.ModelVersionManager
ModelWarmupUtility - Class in com.codedstreams.otterstreams.sql.runtime: Utility for warming up models to avoid cold start latency.
ModelWarmupUtility() - Constructor for class com.codedstreams.otterstreams.sql.runtime.ModelWarmupUtility

N

NONE - com.codedstream.otterstream.inference.cache.CacheStrategy: No caching - all inferences go directly to the model
normalize(Map<String, Object>, Map<String, Double>, Map<String, Double>) - Static method in class com.codedstreams.otterstreams.sql.util.FeaturePreprocessor: Normalizes numerical features to [0, 1] range.
normalizeOptionKey(String) - Static method in class com.codedstreams.otterstreams.sql.util.DDLParserHelper: Converts option key to standard format.

O

oneHotEncode(Map<String, Object>, Map<String, String[]>) - Static method in class com.codedstreams.otterstreams.sql.util.FeaturePreprocessor: One-hot encodes categorical features.
ONNX - com.codedstream.otterstream.inference.model.ModelFormat: Open Neural Network Exchange format - cross-platform standard
OnnxInferenceEngine - Class in com.codedstream.otterstream.onnx: ONNX Runtime implementation of LocalInferenceEngine for ML inference.
OnnxInferenceEngine() - Constructor for class com.codedstream.otterstream.onnx.OnnxInferenceEngine
OnnxModelLoader - Class in com.codedstream.otterstream.onnx: ModelLoader implementation for loading ONNX models.
OnnxModelLoader() - Constructor for class com.codedstream.otterstream.onnx.OnnxModelLoader
open(Configuration) - Method in class com.codedstreams.otterstreams.sql.async.AsyncMLPredictFunction
open(FunctionContext) - Method in class com.codedstreams.otterstreams.sql.connector.MLInferenceLookupFunction
OPEN - com.codedstreams.otterstreams.sql.runtime.InferenceCircuitBreaker.State
openStream() - Method in interface com.codedstreams.otterstreams.sql.loader.ModelSource: Opens an input stream to read the model.
optionalOptions() - Method in class com.codedstreams.otterstreams.sql.connector.MLInferenceDynamicTableFactory
OtterStreamSQLConstants - Class in com.codedstreams.otterstreams.sql: Constants used throughout Otter Stream SQL module.
outputSchema(Map<String, Object>) - Method in class com.codedstream.otterstream.inference.model.ModelMetadata.Builder: Sets the output schema.

P

parseWithClause(String) - Static method in class com.codedstreams.otterstreams.sql.util.DDLParserHelper: Parses WITH clause options from DDL.
PatternInferenceFunction<T,R> - Class in com.codedstreams.otterstreams.sql.cep: Process function that applies ML inference to CEP pattern matches.
PatternInferenceFunction(String) - Constructor for class com.codedstreams.otterstreams.sql.cep.PatternInferenceFunction
PMML - com.codedstream.otterstream.inference.model.ModelFormat: Predictive Model Markup Language - XML-based standard
PmmlInferenceEngine - Class in com.codedstream.otterstream.pmml: PMML (Predictive Model Markup Language) implementation of LocalInferenceEngine.
PmmlInferenceEngine() - Constructor for class com.codedstream.otterstream.pmml.PmmlInferenceEngine
processMatch(Map<String, List<T>>, PatternProcessFunction.Context, Collector<R>) - Method in class com.codedstreams.otterstreams.sql.cep.PatternInferenceFunction
put(String, Object) - Method in class com.codedstreams.otterstreams.sql.runtime.InferenceContext
put(K, V) - Method in class com.codedstream.otterstream.inference.cache.ModelCache: Stores a value in the cache.
putEngine(String, InferenceEngine<?>) - Method in class com.codedstreams.otterstreams.sql.loader.ModelCache
putMetadata(String, Object) - Method in class com.codedstreams.otterstreams.sql.loader.ModelLoadingContext
PYTORCH_TORCHSCRIPT - com.codedstream.otterstream.inference.model.ModelFormat: PyTorch TorchScript format - serialized PyTorch models

R

readTimeoutMs(long) - Method in class com.codedstreams.otterstreams.sql.config.EndpointConfig.Builder
readTimeoutMs(long) - Method in class com.codedstreams.otterstreams.sql.config.ModelSourceConfig.Builder
recordBatchSize(int) - Method in class com.codedstream.otterstream.inference.metrics.InferenceMetrics: Records the size of a batch inference operation.
recordCacheHit() - Method in class com.codedstream.otterstream.inference.metrics.InferenceMetrics: Records a cache hit event.
recordCacheHit(String) - Method in class com.codedstreams.otterstreams.sql.runtime.InferenceMetricsCollector
recordCacheMiss() - Method in class com.codedstream.otterstream.inference.metrics.InferenceMetrics: Records a cache miss event.
recordCacheMiss(String) - Method in class com.codedstreams.otterstreams.sql.runtime.InferenceMetricsCollector
recordInference(long, boolean) - Method in class com.codedstream.otterstream.inference.metrics.InferenceMetrics: Records an inference operation with duration and outcome.
recordInference(String, long, boolean) - Method in class com.codedstreams.otterstreams.sql.runtime.InferenceMetricsCollector
region(String) - Method in class com.codedstreams.otterstreams.sql.config.ModelSourceConfig.Builder
registerAllFunctions(TableEnvironment) - Static method in class com.codedstreams.otterstreams.sql.udf.FunctionRegistrationHelper: Registers all Otter Stream SQL functions.
registerAndLoadModel(SqlInferenceConfig) - Method in class com.codedstreams.otterstreams.sql.loader.ModelRegistrationManager: Registers and loads a model from configuration.
registerModel(String, InferenceEngine<?>) - Method in class com.codedstreams.otterstreams.sql.runtime.ModelHealthChecker
registerModel(String, ModelDescriptor) - Method in class com.codedstreams.otterstreams.sql.metadata.ModelRegistry
ReinforcementHandler - Class in com.codedstreams.otterstreams.sql.cep: Handles feedback loops for reinforcement learning scenarios.
ReinforcementHandler() - Constructor for class com.codedstreams.otterstreams.sql.cep.ReinforcementHandler
reloadModel(String, SqlInferenceConfig) - Method in class com.codedstreams.otterstreams.sql.loader.ModelRegistrationManager: Reloads a model with new configuration.
REMOTE_GRPC - com.codedstream.otterstream.inference.model.ModelFormat: Remote gRPC endpoint
REMOTE_HTTP - com.codedstream.otterstream.inference.model.ModelFormat: Remote HTTP/REST endpoint
RemoteInferenceEngine - Class in com.codedstream.otterstream.remote: Abstract base class for remote inference engines communicating with external model endpoints.
RemoteInferenceEngine() - Constructor for class com.codedstream.otterstream.remote.RemoteInferenceEngine
removeProgress(String) - Method in class com.codedstreams.otterstreams.sql.loader.ModelLoadingProgressTracker
requiredOptions() - Method in class com.codedstreams.otterstreams.sql.connector.MLInferenceDynamicTableFactory
requirements() - Method in class com.codedstreams.otterstreams.sql.udf.MLInferenceFunctionFactory
reset(String) - Method in class com.codedstreams.otterstreams.sql.runtime.InferenceMetricsCollector
resetAll() - Method in class com.codedstreams.otterstreams.sql.runtime.InferenceMetricsCollector
resultCacheEnabled(boolean) - Method in class com.codedstreams.otterstreams.sql.config.CacheConfig.Builder
resultCacheMaxSize(int) - Method in class com.codedstreams.otterstreams.sql.config.CacheConfig.Builder
resultCacheTtl(Duration) - Method in class com.codedstreams.otterstreams.sql.config.CacheConfig.Builder
ResultPostprocessor - Class in com.codedstreams.otterstreams.sql.util: Postprocesses inference results (denormalization, thresholding, etc.).
ResultPostprocessor() - Constructor for class com.codedstreams.otterstreams.sql.util.ResultPostprocessor
retryBackoffMs(long) - Method in class com.codedstreams.otterstreams.sql.config.SqlInferenceConfig.Builder
RuleEngineProvider - Class in com.codedstreams.otterstreams.sql.udf: Provides a rule engine instance for Flink SQL and DataStream pipelines.
RuleOutcome - Class in com.codedstreams.otterstreams.sql.rules: Mutable rule outcome passed as a Drools global.
RuleOutcome() - Constructor for class com.codedstreams.otterstreams.sql.rules.RuleOutcome

S

S3 - com.codedstreams.otterstreams.sql.config.ModelSourceConfig.SourceType
S3ModelLoader - Class in com.codedstreams.otterstreams.sql.loader: Loads ML models from AWS S3 or S3-compatible storage (e.g.
S3ModelLoader(ModelSourceConfig) - Constructor for class com.codedstreams.otterstreams.sql.loader.S3ModelLoader
SAGEMAKER - com.codedstream.otterstream.inference.model.ModelFormat: AWS SageMaker hosting service
SageMakerInferenceClient - Class in com.codedstream.otterstream.remote.sagemaker: AWS SageMaker remote inference client for hosted ML models.
SageMakerInferenceClient() - Constructor for class com.codedstream.otterstream.remote.sagemaker.SageMakerInferenceClient
SerializationUtils - Class in com.codedstreams.otterstreams.sql.util: Serialization utilities for distributing objects in Flink.
SerializationUtils() - Constructor for class com.codedstreams.otterstreams.sql.util.SerializationUtils
serialize(T) - Static method in class com.codedstreams.otterstreams.sql.util.SerializationUtils
shutdown() - Method in class com.codedstreams.otterstreams.sql.async.AsyncInferenceExecutor: Shuts down the executor, preventing new tasks from being submitted.
shutdown() - Method in class com.codedstreams.otterstreams.sql.loader.ModelServerConnectionPool
sigmoid(double) - Static method in class com.codedstreams.otterstreams.sql.util.ResultPostprocessor: Applies sigmoid to convert logits to probability.
size() - Method in class com.codedstream.otterstream.inference.cache.ModelCache: Returns the approximate current size of the cache.
softmax(double[]) - Static method in class com.codedstreams.otterstreams.sql.util.ResultPostprocessor: Applies softmax to convert logits to probabilities.
SqlInferenceConfig - Class in com.codedstreams.otterstreams.sql.config: Configuration for SQL-based ML inference operations.
SqlInferenceConfig.Builder - Class in com.codedstreams.otterstreams.sql.config
standardize(Map<String, Object>, Map<String, Double>, Map<String, Double>) - Static method in class com.codedstreams.otterstreams.sql.util.FeaturePreprocessor: Standardizes features to zero mean and unit variance.
start() - Method in class com.codedstreams.otterstreams.sql.runtime.BatchInferenceProcessor
start(long) - Method in class com.codedstreams.otterstreams.sql.runtime.ModelHealthChecker
startLoading(String) - Method in class com.codedstreams.otterstreams.sql.loader.ModelLoadingProgressTracker
stop() - Method in class com.codedstreams.otterstreams.sql.runtime.BatchInferenceProcessor
stop() - Method in class com.codedstreams.otterstreams.sql.runtime.ModelHealthChecker
submit(Supplier<T>) - Method in class com.codedstreams.otterstreams.sql.async.AsyncInferenceExecutor: Submits a task for asynchronous execution.
submitAndWait(Map<String, Object>) - Method in class com.codedstreams.otterstreams.sql.runtime.BatchInferenceProcessor: Submits an inference request and waits for result.
sumScore - Variable in class com.codedstreams.otterstreams.sql.udf.MLPredictAggregateFunction.Accumulator
supportsBatching() - Method in class com.codedstream.otterstream.inference.engine.InferenceEngine.EngineCapabilities
supportsGPU() - Method in class com.codedstream.otterstream.inference.engine.InferenceEngine.EngineCapabilities
supportsStreaming() - Method in class com.codedstream.otterstream.inference.engine.InferenceEngine.EngineCapabilities

T

TensorConverter - Class in com.codedstreams.otterstreams.sql.util: Converts between Java objects and TensorFlow tensors.
TensorConverter() - Constructor for class com.codedstreams.otterstreams.sql.util.TensorConverter
TENSORFLOW_GRAPHDEF - com.codedstream.otterstream.inference.model.ModelFormat: TensorFlow GraphDef format - TensorFlow 1.x frozen graphs
TENSORFLOW_SAVEDMODEL - com.codedstream.otterstream.inference.model.ModelFormat: TensorFlow SavedModel format - TensorFlow 2.x default
TensorFlowGraphDefEngine - Class in com.codedstreams.otterstreams.sql.runtime: TensorFlow GraphDef (frozen graph) inference engine.
TensorFlowGraphDefEngine() - Constructor for class com.codedstreams.otterstreams.sql.runtime.TensorFlowGraphDefEngine
TensorFlowInferenceEngine - Class in com.codedstream.otterstream.tensorflow: TensorFlow SavedModel inference engine using TensorFlow Java API.
TensorFlowInferenceEngine() - Constructor for class com.codedstream.otterstream.tensorflow.TensorFlowInferenceEngine
TensorFlowSavedModelEngine - Class in com.codedstreams.otterstreams.sql.runtime: TensorFlow SavedModel inference engine.
TensorFlowSavedModelEngine() - Constructor for class com.codedstreams.otterstreams.sql.runtime.TensorFlowSavedModelEngine
timeout(IN, ResultFuture<OUT>) - Method in class com.codedstream.otterstream.inference.function.AsyncModelInferenceFunction: Called when inference timeout occurs.
timeout(Duration) - Method in class com.codedstream.otterstream.inference.config.InferenceConfig.Builder: Sets the inference timeout using Duration.
timeoutMs(long) - Method in class com.codedstream.otterstream.inference.config.InferenceConfig.Builder: Sets the inference timeout in milliseconds.
toCoreConfig() - Method in class com.codedstreams.otterstreams.sql.config.SqlInferenceConfig: Converts this config to core InferenceConfig for compatibility.
token(String) - Method in class com.codedstream.otterstream.inference.config.AuthConfig.Builder: Sets the bearer token.
topK(double[], int) - Static method in class com.codedstreams.otterstreams.sql.util.ResultPostprocessor: Extracts top-k predictions.
TorchScriptInferenceEngine - Class in com.codedstream.otterstream.pytorch: TorchScript (PyTorch) implementation of LocalInferenceEngine using Deep Java Library (DJL).
TorchScriptInferenceEngine() - Constructor for class com.codedstream.otterstream.pytorch.TorchScriptInferenceEngine
toString() - Method in class com.codedstream.otterstream.inference.model.ModelMetadata: Returns a string representation of the model metadata.
toString() - Method in class com.codedstreams.otterstreams.sql.config.CacheConfig
toString() - Method in class com.codedstreams.otterstreams.sql.config.ModelSourceConfig
toString() - Method in class com.codedstreams.otterstreams.sql.config.SqlInferenceConfig
toString() - Method in class com.codedstreams.otterstreams.sql.runtime.InferenceMetricsCollector.ModelMetrics
toTensor(Object) - Static method in class com.codedstreams.otterstreams.sql.util.TensorConverter: Converts a Java object to a TensorFlow tensor.
transformResult(IN, InferenceResult) - Method in class com.codedstream.otterstream.inference.function.AsyncModelInferenceFunction: Transforms inference result into output record.
trigger() - Method in class com.codedstreams.otterstreams.sql.rules.RuleOutcome
triggerRetraining(String) - Method in class com.codedstreams.otterstreams.sql.cep.ReinforcementHandler
ttl(Duration) - Method in class com.codedstreams.otterstreams.sql.config.CacheConfig.Builder
ttlMs(long) - Method in class com.codedstreams.otterstreams.sql.config.CacheConfig.Builder
TypeUtils - Class in com.codedstreams.otterstreams.sql.util: Utilities for Flink type conversions.
TypeUtils() - Constructor for class com.codedstreams.otterstreams.sql.util.TypeUtils

U

unregisterAllFunctions(TableEnvironment) - Static method in class com.codedstreams.otterstreams.sql.udf.FunctionRegistrationHelper: Unregisters all Otter Stream SQL functions.
unregisterModel(String) - Method in class com.codedstreams.otterstreams.sql.loader.ModelRegistrationManager: Unregisters and closes a model.
unregisterModel(String) - Method in class com.codedstreams.otterstreams.sql.metadata.ModelRegistry
unregisterModel(String) - Method in class com.codedstreams.otterstreams.sql.runtime.ModelHealthChecker
updateAccessTime() - Method in class com.codedstreams.otterstreams.sql.runtime.ModelSession
updateProgress(String, int) - Method in class com.codedstreams.otterstreams.sql.loader.ModelLoadingProgressTracker.LoadingProgress
updateProgress(String, String, int) - Method in class com.codedstreams.otterstreams.sql.loader.ModelLoadingProgressTracker
url(String) - Method in class com.codedstreams.otterstreams.sql.config.EndpointConfig.Builder

V

validate(SqlInferenceConfig) - Static method in class com.codedstreams.otterstreams.sql.config.ConfigurationValidator: Validates SQL inference configuration.
validateConnection() - Method in class com.codedstream.otterstream.remote.http.HttpInferenceClient: Validates connection to remote endpoint using HTTP HEAD request.
validateConnection() - Method in class com.codedstream.otterstream.remote.RemoteInferenceEngine: Validates connection to remote endpoint (abstract).
validateConnection() - Method in class com.codedstream.otterstream.remote.sagemaker.SageMakerInferenceClient: Validates connection to SageMaker endpoint by sending a test inference.
validateFeatures(Map<String, Object>) - Static method in class com.codedstreams.otterstreams.sql.util.ValidationUtils
validateModel(InferenceSession, ModelConfig) - Method in class com.codedstream.otterstream.onnx.OnnxModelLoader: Validates that a loaded ONNX model matches the configuration.
validateModel(T, ModelConfig) - Method in interface com.codedstream.otterstream.inference.model.ModelLoader: Validates that a loaded model matches the configuration.
validateModelPath(String) - Static method in class com.codedstreams.otterstreams.sql.util.ValidationUtils
ValidationResult(List<String>, List<String>) - Constructor for class com.codedstreams.otterstreams.sql.config.ConfigurationValidator.ValidationResult
ValidationUtils - Class in com.codedstreams.otterstreams.sql.util: Validation utilities for input data.
ValidationUtils() - Constructor for class com.codedstreams.otterstreams.sql.util.ValidationUtils
valueOf(String) - Static method in enum com.codedstream.otterstream.inference.cache.CacheStrategy: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.codedstream.otterstream.inference.model.ModelFormat: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.codedstreams.otterstreams.sql.config.ModelSourceConfig.SourceType: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum com.codedstreams.otterstreams.sql.runtime.InferenceCircuitBreaker.State: Returns the enum constant of this type with the specified name.
values() - Static method in enum com.codedstream.otterstream.inference.cache.CacheStrategy: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.codedstream.otterstream.inference.model.ModelFormat: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.codedstreams.otterstreams.sql.config.ModelSourceConfig.SourceType: Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum com.codedstreams.otterstreams.sql.runtime.InferenceCircuitBreaker.State: Returns an array containing the constants of this enum type, in the order they are declared.
VERTEX_AI - com.codedstream.otterstream.inference.model.ModelFormat: Google Cloud Vertex AI service
VertexAIInferenceClient - Class in com.codedstream.otterstream.remote.vertex: Google Vertex AI remote inference client for Google Cloud ML models.
VertexAIInferenceClient(InferenceConfig) - Constructor for class com.codedstream.otterstream.remote.vertex.VertexAIInferenceClient: Constructs a new Vertex AI inference client with the provided configuration.

W

warmupModel(String) - Static method in class com.codedstreams.otterstreams.sql.runtime.ModelWarmupUtility: Warms up a model by running a dummy inference.
warmupModels(String...) - Static method in class com.codedstreams.otterstreams.sql.runtime.ModelWarmupUtility: Warms up multiple models.
withMLCondition(Pattern<T, T>, String, Function<T, Map<String, Object>>, Predicate<Double>) - Static method in class com.codedstreams.otterstreams.sql.cep.CEPInferenceIntegration

X

XGBOOST_BINARY - com.codedstream.otterstream.inference.model.ModelFormat: XGBoost binary format - gradient boosting models
XGBOOST_JSON - com.codedstream.otterstream.inference.model.ModelFormat
XGBoostInferenceEngine - Class in com.codedstream.otterstream.xgboost: XGBoost inference engine for gradient boosting tree models.
XGBoostInferenceEngine() - Constructor for class com.codedstream.otterstream.xgboost.XGBoostInferenceEngine

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