Package com.codedstreams.otterstreams.sql.udf
-
Class Summary Class Description FunctionRegistrationHelper Helper class for registering SQL functions programmatically.MLInferenceFunction Flink SQL scalar function for ML inference.MLInferenceFunctionFactory MLPredictAggregateFunction Aggregate function for batch inference over windows.MLPredictAggregateFunction.Accumulator MLPredictScalarFunction Flink SQL Scalar Function for ML model inference.MLPredictTableFunction Table function that returns multiple rows.RuleEngineProvider Provides a rule engine instance for Flink SQL and DataStream pipelines.