Class RichIterativeCondition<T>
- java.lang.Object
-
- org.apache.flink.cep.pattern.conditions.IterativeCondition<T>
-
- org.apache.flink.cep.pattern.conditions.RichIterativeCondition<T>
-
- All Implemented Interfaces:
Serializable,org.apache.flink.api.common.functions.Function,org.apache.flink.api.common.functions.RichFunction
- Direct Known Subclasses:
RichCompositeIterativeCondition
public abstract class RichIterativeCondition<T> extends IterativeCondition<T> implements org.apache.flink.api.common.functions.RichFunction
Rich variant of theIterativeCondition. As aRichFunction, it gives access to theRuntimeContextand provides setup and teardown methods:RichFunction.open(OpenContext)andRichFunction.close().- See Also:
- Serialized Form
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class org.apache.flink.cep.pattern.conditions.IterativeCondition
IterativeCondition.Context<T>
-
-
Constructor Summary
Constructors Constructor Description RichIterativeCondition()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidclose()org.apache.flink.api.common.functions.IterationRuntimeContextgetIterationRuntimeContext()org.apache.flink.api.common.functions.RuntimeContextgetRuntimeContext()voidopen(org.apache.flink.api.common.functions.OpenContext openContext)voidsetRuntimeContext(org.apache.flink.api.common.functions.RuntimeContext runtimeContext)-
Methods inherited from class org.apache.flink.cep.pattern.conditions.IterativeCondition
filter
-
-
-
-
Method Detail
-
setRuntimeContext
public void setRuntimeContext(org.apache.flink.api.common.functions.RuntimeContext runtimeContext)
- Specified by:
setRuntimeContextin interfaceorg.apache.flink.api.common.functions.RichFunction
-
getRuntimeContext
public org.apache.flink.api.common.functions.RuntimeContext getRuntimeContext()
- Specified by:
getRuntimeContextin interfaceorg.apache.flink.api.common.functions.RichFunction
-
getIterationRuntimeContext
public org.apache.flink.api.common.functions.IterationRuntimeContext getIterationRuntimeContext()
- Specified by:
getIterationRuntimeContextin interfaceorg.apache.flink.api.common.functions.RichFunction
-
open
public void open(org.apache.flink.api.common.functions.OpenContext openContext) throws Exception- Specified by:
openin interfaceorg.apache.flink.api.common.functions.RichFunction- Throws:
Exception
-
-