Package com.codedstreams.otterstreams.sql.cep

Class PatternInferenceFunction<T,R>

java.lang.Object

org.apache.flink.api.common.functions.AbstractRichFunction

org.apache.flink.cep.functions.PatternProcessFunction<T,R>

com.codedstreams.otterstreams.sql.cep.PatternInferenceFunction<T,R>

All Implemented Interfaces:

Serializable, org.apache.flink.api.common.functions.Function, org.apache.flink.api.common.functions.RichFunction

public class PatternInferenceFunction<T,R>
extends org.apache.flink.cep.functions.PatternProcessFunction<T,R>

Process function that applies ML inference to CEP pattern matches.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.flink.cep.functions.PatternProcessFunction

org.apache.flink.cep.functions.PatternProcessFunction.Context

Constructor Summary

Constructors

Constructor	Description
PatternInferenceFunction(String modelName)

Method Summary

Modifier and Type	Method	Description
void	processMatch(Map<String,List<T>> pattern, org.apache.flink.cep.functions.PatternProcessFunction.Context ctx, org.apache.flink.util.Collector<R> out)

Methods inherited from class org.apache.flink.api.common.functions.AbstractRichFunction

close, getIterationRuntimeContext, getRuntimeContext, open, setRuntimeContext

Methods inherited from class java.lang.Object

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

Constructor Detail

PatternInferenceFunction

public PatternInferenceFunction(String modelName)

Method Detail

processMatch

public void processMatch(Map<String,List<T>> pattern,
                         org.apache.flink.cep.functions.PatternProcessFunction.Context ctx,
                         org.apache.flink.util.Collector<R> out)
                  throws Exception

Specified by:

processMatch in class org.apache.flink.cep.functions.PatternProcessFunction<T,R>

Throws:

Exception