Package com.codedstreams.otterstreams.sql.cep

Class CEPInferenceIntegration

java.lang.Object

com.codedstreams.otterstreams.sql.cep.CEPInferenceIntegration

public class CEPInferenceIntegration
extends Object

Integration between Flink CEP and ML inference for pattern-based decisions.

Constructor Summary

Constructors

Constructor	Description
CEPInferenceIntegration()

Method Summary

Modifier and Type	Method	Description
static <T> org.apache.flink.cep.pattern.Pattern<T,T>	withMLCondition(org.apache.flink.cep.pattern.Pattern<T,T> pattern, String modelName, Function<T,Map<String,Object>> featureExtractor, Predicate<Double> scorePredicate)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CEPInferenceIntegration

public CEPInferenceIntegration()

Method Detail

withMLCondition

public static <T> org.apache.flink.cep.pattern.Pattern<T,T> withMLCondition(org.apache.flink.cep.pattern.Pattern<T,T> pattern,
                                                                                  String modelName,
                                                                                  Function<T,Map<String,Object>> featureExtractor,
                                                                                  Predicate<Double> scorePredicate)