Class RichOrCondition<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>
-
- org.apache.flink.cep.pattern.conditions.RichOrCondition<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
@Internal public class RichOrCondition<T> extends RichCompositeIterativeCondition<T>
Aconditionwhich combines two conditions with a logicalORand returnstrueif at least one istrue.- 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 RichOrCondition(IterativeCondition<T> left, IterativeCondition<T> right)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description booleanfilter(T value, IterativeCondition.Context<T> ctx)The filter function that evaluates the predicate.IterativeCondition<T>getLeft()IterativeCondition<T>getRight()-
Methods inherited from class org.apache.flink.cep.pattern.conditions.RichCompositeIterativeCondition
close, getNestedConditions, open, setRuntimeContext
-
Methods inherited from class org.apache.flink.cep.pattern.conditions.RichIterativeCondition
getIterationRuntimeContext, getRuntimeContext
-
-
-
-
Constructor Detail
-
RichOrCondition
public RichOrCondition(IterativeCondition<T> left, IterativeCondition<T> right)
-
-
Method Detail
-
filter
public boolean filter(T value, IterativeCondition.Context<T> ctx) throws Exception
Description copied from class:IterativeConditionThe filter function that evaluates the predicate.IMPORTANT: The system assumes that the function does not modify the elements on which the predicate is applied. Violating this assumption can lead to incorrect results.
- Specified by:
filterin classIterativeCondition<T>- Parameters:
value- The value to be tested.ctx- TheIterativeCondition.Contextused for the evaluation of the function and provides access to the already accepted events in the pattern (seeIterativeCondition.Context.getEventsForPattern(String)).- Returns:
truefor values that should be retained,falsefor values to be filtered out.- Throws:
Exception- This method may throw exceptions. Throwing an exception will cause the operation to fail and may trigger recovery.
-
getLeft
public IterativeCondition<T> getLeft()
- Returns:
- One of the
conditionscombined in this condition.
-
getRight
public IterativeCondition<T> getRight()
- Returns:
- One of the
conditionscombined in this condition.
-
-