Class RichCompositeIterativeCondition<T>
- java.lang.Object
-
- org.apache.flink.cep.pattern.conditions.IterativeCondition<T>
-
- org.apache.flink.cep.pattern.conditions.RichIterativeCondition<T>
-
- org.apache.flink.cep.pattern.conditions.RichCompositeIterativeCondition<T>
-
- Type Parameters:
T- Type of the element to filter
- All Implemented Interfaces:
Serializable,org.apache.flink.api.common.functions.Function,org.apache.flink.api.common.functions.RichFunction
- Direct Known Subclasses:
RichAndCondition,RichNotCondition,RichOrCondition
public abstract class RichCompositeIterativeCondition<T> extends RichIterativeCondition<T>
A base class of compositeIterativeConditionconditions such asRichAndCondition,RichOrConditionandRichNotCondition, etc. It handles the open, close and setRuntimeContext for the nestedIterativeConditionconditions.- 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 RichCompositeIterativeCondition(IterativeCondition<T>... nestedConditions)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidclose()IterativeCondition<T>[]getNestedConditions()voidopen(org.apache.flink.api.common.functions.OpenContext openContext)voidsetRuntimeContext(org.apache.flink.api.common.functions.RuntimeContext t)-
Methods inherited from class org.apache.flink.cep.pattern.conditions.RichIterativeCondition
getIterationRuntimeContext, getRuntimeContext
-
Methods inherited from class org.apache.flink.cep.pattern.conditions.IterativeCondition
filter
-
-
-
-
Constructor Detail
-
RichCompositeIterativeCondition
@SafeVarargs public RichCompositeIterativeCondition(IterativeCondition<T>... nestedConditions)
-
-
Method Detail
-
getNestedConditions
public IterativeCondition<T>[] getNestedConditions()
-
setRuntimeContext
public void setRuntimeContext(org.apache.flink.api.common.functions.RuntimeContext t)
- Specified by:
setRuntimeContextin interfaceorg.apache.flink.api.common.functions.RichFunction- Overrides:
setRuntimeContextin classRichIterativeCondition<T>
-
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 classRichIterativeCondition<T>- Throws:
Exception
-
close
public void close() throws Exception- Specified by:
closein interfaceorg.apache.flink.api.common.functions.RichFunction- Overrides:
closein classRichIterativeCondition<T>- Throws:
Exception
-
-