Class IterativeConditionRunner
- java.lang.Object
-
- org.apache.flink.cep.pattern.conditions.IterativeCondition<T>
-
- org.apache.flink.cep.pattern.conditions.RichIterativeCondition<org.apache.flink.table.data.RowData>
-
- org.apache.flink.table.runtime.operators.match.IterativeConditionRunner
-
- All Implemented Interfaces:
Serializable,org.apache.flink.api.common.functions.Function,org.apache.flink.api.common.functions.RichFunction
public class IterativeConditionRunner extends org.apache.flink.cep.pattern.conditions.RichIterativeCondition<org.apache.flink.table.data.RowData>ARichIterativeConditionwrapper to delegate invocation to the code generatedRichIterativeCondition.- See Also:
- Serialized Form
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class org.apache.flink.cep.pattern.conditions.IterativeCondition
org.apache.flink.cep.pattern.conditions.IterativeCondition.Context<T extends Object>
-
-
Constructor Summary
Constructors Constructor Description IterativeConditionRunner(GeneratedFunction<org.apache.flink.cep.pattern.conditions.RichIterativeCondition<org.apache.flink.table.data.RowData>> generatedFunction)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidclose()booleanfilter(org.apache.flink.table.data.RowData value, org.apache.flink.cep.pattern.conditions.IterativeCondition.Context<org.apache.flink.table.data.RowData> ctx)voidopen(org.apache.flink.api.common.functions.OpenContext openContext)
-
-
-
Constructor Detail
-
IterativeConditionRunner
public IterativeConditionRunner(GeneratedFunction<org.apache.flink.cep.pattern.conditions.RichIterativeCondition<org.apache.flink.table.data.RowData>> generatedFunction)
-
-
Method Detail
-
open
public void open(org.apache.flink.api.common.functions.OpenContext openContext) throws Exception- Specified by:
openin interfaceorg.apache.flink.api.common.functions.RichFunction- Overrides:
openin classorg.apache.flink.cep.pattern.conditions.RichIterativeCondition<org.apache.flink.table.data.RowData>- Throws:
Exception
-
filter
public boolean filter(org.apache.flink.table.data.RowData value, org.apache.flink.cep.pattern.conditions.IterativeCondition.Context<org.apache.flink.table.data.RowData> ctx) throws Exception- Specified by:
filterin classorg.apache.flink.cep.pattern.conditions.IterativeCondition<org.apache.flink.table.data.RowData>- Throws:
Exception
-
-