Hierarchy For All Packages

Package Hierarchies:

• com.codedstream.otterstream.inference.cache,
• com.codedstream.otterstream.inference.config,
• com.codedstream.otterstream.inference.engine,
• com.codedstream.otterstream.inference.exception,
• com.codedstream.otterstream.inference.function,
• com.codedstream.otterstream.inference.metrics,
• com.codedstream.otterstream.inference.model,
• com.codedstream.otterstream.onnx,
• com.codedstream.otterstream.pmml,
• com.codedstream.otterstream.pytorch,
• com.codedstream.otterstream.remote,
• com.codedstream.otterstream.remote.http,
• com.codedstream.otterstream.remote.sagemaker,
• com.codedstream.otterstream.remote.vertex,
• com.codedstream.otterstream.tensorflow,
• com.codedstream.otterstream.xgboost,
• com.codedstreams.otterstream.examples,
• com.codedstreams.otterstreams.sql,
• com.codedstreams.otterstreams.sql.async,
• com.codedstreams.otterstreams.sql.cep,
• com.codedstreams.otterstreams.sql.config,
• com.codedstreams.otterstreams.sql.connector,
• com.codedstreams.otterstreams.sql.loader,
• com.codedstreams.otterstreams.sql.metadata,
• com.codedstreams.otterstreams.sql.rules,
• com.codedstreams.otterstreams.sql.runtime,
• com.codedstreams.otterstreams.sql.udf,
• com.codedstreams.otterstreams.sql.util

Class Hierarchy

• java.lang.Object
  • org.apache.flink.api.common.functions.AbstractRichFunction (implements org.apache.flink.api.common.functions.RichFunction, java.io.Serializable)
    • com.codedstream.otterstream.inference.function.AsyncModelInferenceFunction<IN,OUT> (implements org.apache.flink.streaming.api.functions.async.AsyncFunction<IN,OUT>)
    • org.apache.flink.cep.functions.PatternProcessFunction<IN,OUT>
      • com.codedstreams.otterstreams.sql.cep.PatternInferenceFunction<T,R>
    • org.apache.flink.streaming.api.functions.async.RichAsyncFunction<IN,OUT> (implements org.apache.flink.streaming.api.functions.async.AsyncFunction<IN,OUT>)
      • com.codedstreams.otterstreams.sql.async.AsyncMLPredictFunction
  • com.codedstreams.otterstreams.sql.async.AsyncInferenceExecutor
  • com.codedstreams.otterstreams.sql.async.AsyncMLInferenceFunction<T,R> (implements org.apache.flink.streaming.api.functions.async.AsyncFunction<IN,OUT>)
  • com.codedstreams.otterstreams.sql.async.AsyncResultHandler<T>
  • com.codedstream.otterstream.inference.config.AuthConfig
  • com.codedstream.otterstream.inference.config.AuthConfig.Builder
  • com.codedstreams.otterstreams.sql.runtime.BatchInferenceProcessor
  • com.codedstreams.otterstreams.sql.config.CacheConfig (implements java.io.Serializable)
  • com.codedstreams.otterstreams.sql.config.CacheConfig.Builder
  • com.codedstreams.otterstreams.sql.cep.CEPInferenceIntegration
  • com.codedstreams.otterstreams.sql.config.ConfigurationValidator
  • com.codedstreams.otterstreams.sql.config.ConfigurationValidator.ValidationResult
  • com.codedstreams.otterstreams.sql.util.DDLParserHelper
  • com.codedstreams.otterstreams.sql.rules.DroolsDecisionEngine (implements com.codedstreams.otterstreams.sql.rules.DecisionEngine<T>)
  • com.codedstreams.otterstreams.sql.config.EndpointConfig (implements java.io.Serializable)
  • com.codedstreams.otterstreams.sql.config.EndpointConfig.Builder
  • com.codedstreams.otterstreams.sql.util.FeaturePreprocessor
  • com.codedstreams.otterstream.examples.FraudDetectionExample
  • com.codedstreams.otterstreams.sql.udf.FunctionRegistrationHelper
  • com.codedstreams.otterstreams.sql.loader.HttpModelLoader (implements com.codedstreams.otterstreams.sql.loader.ModelLoader)
  • com.codedstreams.otterstreams.sql.runtime.InferenceCircuitBreaker
  • com.codedstream.otterstream.inference.config.InferenceConfig
  • com.codedstream.otterstream.inference.config.InferenceConfig.Builder
  • com.codedstreams.otterstreams.sql.runtime.InferenceContext
  • com.codedstream.otterstream.inference.engine.InferenceEngine.EngineCapabilities
  • com.codedstreams.otterstreams.sql.runtime.InferenceEngineFactory
  • com.codedstreams.otterstreams.sql.util.InferenceErrorBuilder
  • com.codedstream.otterstream.inference.metrics.InferenceMetrics
  • com.codedstreams.otterstreams.sql.runtime.InferenceMetricsCollector
  • com.codedstreams.otterstreams.sql.runtime.InferenceMetricsCollector.ModelMetrics
  • com.codedstream.otterstream.inference.model.InferenceResult
  • com.codedstreams.otterstreams.sql.runtime.InferenceRetryHandler
  • com.codedstream.otterstream.onnx.InferenceSession
  • com.codedstreams.otterstreams.sql.metadata.InputOutputSchema (implements java.io.Serializable)
  • com.codedstreams.otterstreams.sql.metadata.InputOutputSchema.FieldSchema (implements java.io.Serializable)
  • com.codedstreams.otterstreams.sql.metadata.InputOutputSchemaExtractor
  • com.codedstreams.otterstreams.sql.util.JsonFeatureExtractor
  • com.codedstream.otterstream.inference.engine.LocalInferenceEngine<T> (implements com.codedstream.otterstream.inference.engine.InferenceEngine<T>)
    • com.codedstream.otterstream.onnx.OnnxInferenceEngine
    • com.codedstream.otterstream.pmml.PmmlInferenceEngine
    • com.codedstreams.otterstreams.sql.runtime.TensorFlowGraphDefEngine
    • com.codedstream.otterstream.tensorflow.TensorFlowInferenceEngine
    • com.codedstreams.otterstreams.sql.runtime.TensorFlowSavedModelEngine
    • com.codedstream.otterstream.pytorch.TorchScriptInferenceEngine
    • com.codedstream.otterstream.xgboost.XGBoostInferenceEngine
  • com.codedstreams.otterstreams.sql.loader.LocalModelLoader (implements com.codedstreams.otterstreams.sql.loader.ModelLoader)
  • com.codedstream.otterstream.inference.metrics.MetricsCollector
  • com.codedstreams.otterstreams.sql.loader.MinioModelLoader (implements com.codedstreams.otterstreams.sql.loader.ModelLoader)
  • com.codedstreams.otterstreams.sql.connector.MLInferenceDynamicTableFactory (implements org.apache.flink.table.factories.DynamicTableSourceFactory)
  • com.codedstreams.otterstreams.sql.connector.MLInferenceDynamicTableSource (implements org.apache.flink.table.connector.source.LookupTableSource)
  • com.codedstreams.otterstreams.sql.udf.MLInferenceFunctionFactory (implements org.apache.flink.table.factories.FunctionDefinitionFactory)
  • com.codedstreams.otterstreams.sql.udf.MLPredictAggregateFunction.Accumulator
  • com.codedstream.otterstream.inference.cache.ModelCache<K,V>
  • com.codedstreams.otterstreams.sql.loader.ModelCache
  • com.codedstream.otterstream.inference.config.ModelConfig
  • com.codedstream.otterstream.inference.config.ModelConfig.Builder
  • com.codedstreams.otterstreams.sql.metadata.ModelDescriptor (implements java.io.Serializable)
  • com.codedstreams.otterstreams.sql.runtime.ModelHealthChecker
  • com.codedstreams.otterstreams.sql.runtime.ModelHealthChecker.HealthStatus
  • com.codedstreams.otterstreams.sql.loader.ModelLoaderFactory
  • com.codedstreams.otterstreams.sql.loader.ModelLoadingContext
  • com.codedstreams.otterstreams.sql.loader.ModelLoadingProgressTracker
  • com.codedstreams.otterstreams.sql.loader.ModelLoadingProgressTracker.LoadingProgress
  • com.codedstream.otterstream.inference.model.ModelMetadata
  • com.codedstream.otterstream.inference.model.ModelMetadata.Builder
  • com.codedstreams.otterstreams.sql.loader.ModelRegistrationManager
  • com.codedstreams.otterstreams.sql.metadata.ModelRegistry
  • com.codedstreams.otterstreams.sql.loader.ModelServerConnectionPool
  • com.codedstreams.otterstreams.sql.runtime.ModelSession (implements java.io.Serializable)
  • com.codedstreams.otterstreams.sql.config.ModelSourceConfig (implements java.io.Serializable)
  • com.codedstreams.otterstreams.sql.config.ModelSourceConfig.Builder
  • com.codedstreams.otterstreams.sql.metadata.ModelVersionManager
  • com.codedstreams.otterstreams.sql.runtime.ModelWarmupUtility
  • com.codedstream.otterstream.onnx.OnnxModelLoader (implements com.codedstream.otterstream.inference.model.ModelLoader<T>)
  • com.codedstreams.otterstreams.sql.OtterStreamSQLConstants
  • com.codedstreams.otterstreams.sql.cep.ReinforcementHandler
  • com.codedstream.otterstream.remote.RemoteInferenceEngine (implements com.codedstream.otterstream.inference.engine.InferenceEngine<T>)
    • com.codedstream.otterstream.remote.http.HttpInferenceClient
    • com.codedstream.otterstream.remote.sagemaker.SageMakerInferenceClient
  • com.codedstreams.otterstreams.sql.util.ResultPostprocessor
  • com.codedstreams.otterstreams.sql.udf.RuleEngineProvider
  • com.codedstreams.otterstreams.sql.rules.RuleOutcome
  • com.codedstreams.otterstreams.sql.loader.S3ModelLoader (implements com.codedstreams.otterstreams.sql.loader.ModelLoader)
  • com.codedstreams.otterstreams.sql.util.SerializationUtils
  • com.codedstreams.otterstreams.sql.config.SqlInferenceConfig (implements java.io.Serializable)
  • com.codedstreams.otterstreams.sql.config.SqlInferenceConfig.Builder
  • com.codedstreams.otterstreams.sql.util.TensorConverter
  • java.lang.Throwable (implements java.io.Serializable)
    • java.lang.Exception
      • com.codedstream.otterstream.inference.exception.InferenceException
      • com.codedstream.otterstream.inference.exception.ModelLoadException
  • com.codedstreams.otterstreams.sql.util.TypeUtils
  • org.apache.flink.table.functions.UserDefinedFunction (implements org.apache.flink.table.functions.FunctionDefinition, java.io.Serializable)
    • org.apache.flink.table.functions.ImperativeAggregateFunction<T,ACC>
      • org.apache.flink.table.functions.AggregateFunction<T,ACC>
        • com.codedstreams.otterstreams.sql.udf.MLPredictAggregateFunction
    • org.apache.flink.table.functions.ScalarFunction
      • com.codedstreams.otterstreams.sql.udf.MLInferenceFunction
      • com.codedstreams.otterstreams.sql.udf.MLPredictScalarFunction
    • org.apache.flink.table.functions.TableFunction<T>
      • com.codedstreams.otterstreams.sql.connector.MLInferenceLookupFunction
      • com.codedstreams.otterstreams.sql.udf.MLPredictTableFunction
  • com.codedstreams.otterstreams.sql.util.ValidationUtils
  • com.codedstream.otterstream.remote.vertex.VertexAIInferenceClient (implements com.codedstream.otterstream.inference.engine.InferenceEngine<T>)

Interface Hierarchy

• com.codedstreams.otterstreams.sql.rules.DecisionEngine<T>
• com.codedstream.otterstream.inference.engine.InferenceEngine<T>
• com.codedstream.otterstream.inference.model.ModelLoader<T>
• com.codedstreams.otterstreams.sql.loader.ModelLoader
• com.codedstreams.otterstreams.sql.loader.ModelSource

Enum Hierarchy

• java.lang.Object
  • java.lang.Enum<E> (implements java.lang.Comparable<T>, java.io.Serializable)
    • com.codedstream.otterstream.inference.cache.CacheStrategy
    • com.codedstreams.otterstreams.sql.runtime.InferenceCircuitBreaker.State
    • com.codedstream.otterstream.inference.model.ModelFormat
    • com.codedstreams.otterstreams.sql.config.ModelSourceConfig.SourceType