Class RuleEngineProvider
- java.lang.Object
-
- com.codedstreams.otterstreams.sql.udf.RuleEngineProvider
-
public final class RuleEngineProvider extends Object
Provides a rule engine instance for Flink SQL and DataStream pipelines.Uses lazy initialization to ensure:
- One engine per task
- No serialization of Drools internals
- Fast startup and reuse
Used By
- Flink SQL UDFs
- DataStream operators
- CEP conditions
-
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static DecisionEngine<Object>get()Returns a lazily initialized decision engine.
-
-
-
Method Detail
-
get
public static DecisionEngine<Object> get()
Returns a lazily initialized decision engine.
-
-