Class SqlInferenceConfig
- java.lang.Object
-
- com.codedstreams.otterstreams.sql.config.SqlInferenceConfig
-
- All Implemented Interfaces:
Serializable
public class SqlInferenceConfig extends Object implements Serializable
Configuration for SQL-based ML inference operations.This class extends the core
InferenceConfigwith SQL-specific settings including model source configuration, caching policies, and SQL DDL options.- Since:
- 1.0.0
- Author:
- Nestor Martourez Abiangang A.
- See Also:
- Serialized Form
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classSqlInferenceConfig.Builder
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static SqlInferenceConfig.Builderbuilder()Builder for SqlInferenceConfig with sensible defaults.static SqlInferenceConfigfromOptions(Map<String,String> options)Creates configuration from SQL DDL options.Map<String,String>getAdditionalOptions()longgetAsyncTimeoutMs()intgetBatchSize()longgetBatchTimeoutMs()CacheConfiggetCacheConfig()intgetMaxRetries()StringgetModelName()ModelSourceConfiggetModelSource()StringgetModelVersion()longgetRetryBackoffMs()booleanisAsyncEnabled()InferenceConfigtoCoreConfig()Converts this config to core InferenceConfig for compatibility.StringtoString()
-
-
-
Method Detail
-
fromOptions
public static SqlInferenceConfig fromOptions(Map<String,String> options)
Creates configuration from SQL DDL options.- Parameters:
options- map of option key-value pairs from WITH clause- Returns:
- configured SqlInferenceConfig
- Throws:
IllegalArgumentException- if required options are missing
-
toCoreConfig
public InferenceConfig toCoreConfig()
Converts this config to core InferenceConfig for compatibility.- Returns:
- InferenceConfig instance
-
getModelName
public String getModelName()
-
getModelSource
public ModelSourceConfig getModelSource()
-
getModelVersion
public String getModelVersion()
-
getBatchSize
public int getBatchSize()
-
getBatchTimeoutMs
public long getBatchTimeoutMs()
-
isAsyncEnabled
public boolean isAsyncEnabled()
-
getAsyncTimeoutMs
public long getAsyncTimeoutMs()
-
getCacheConfig
public CacheConfig getCacheConfig()
-
getMaxRetries
public int getMaxRetries()
-
getRetryBackoffMs
public long getRetryBackoffMs()
-
builder
public static SqlInferenceConfig.Builder builder()
Builder for SqlInferenceConfig with sensible defaults.
-
-