Class 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 Detail