Class DroolsDecisionEngine

  • All Implemented Interfaces:
    DecisionEngine<Object>

    public class DroolsDecisionEngine
    extends Object
    implements DecisionEngine<Object>
    Stateless Drools-based decision engine.

    Designed for Flink streaming workloads:

    • No mutable global state
    • Thread-safe per task
    • Fast rule evaluation
    Since:
    1.0.0
    Author:
    Nestor Martourez, Sr Software and Data Streaming Engineer @ CodedStreams
    • Constructor Detail

      • DroolsDecisionEngine

        public DroolsDecisionEngine​(org.kie.api.runtime.StatelessKieSession session)
    • Method Detail

      • evaluate

        public boolean evaluate​(Object input)
        Description copied from interface: DecisionEngine
        Evaluates the input against configured rules.
        Specified by:
        evaluate in interface DecisionEngine<Object>
        Parameters:
        input - input facts
        Returns:
        true if any rule is triggered