Package beamline.filters
Class RetainOnCaseAttributeEqualityFilter<T extends Serializable>
- java.lang.Object
-
- beamline.filters.RetainOnCaseAttributeEqualityFilter<T>
-
- Type Parameters:
T
- the type of the attribute
- All Implemented Interfaces:
Serializable
,org.apache.flink.api.common.functions.FilterFunction<BEvent>
,org.apache.flink.api.common.functions.Function
public class RetainOnCaseAttributeEqualityFilter<T extends Serializable> extends Object implements org.apache.flink.api.common.functions.FilterFunction<BEvent>
This filter retains events based on the equality of a certain trace attribute to a given set of values. Values are considered in disjunction (i.e., it is enough that the attribute is equal to one of the values to retain the event).- Author:
- Andrea Burattin
- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description RetainOnCaseAttributeEqualityFilter(String attributeName, T... values)
Constructor
-
-
-
Constructor Detail
-
RetainOnCaseAttributeEqualityFilter
@SafeVarargs public RetainOnCaseAttributeEqualityFilter(String attributeName, T... values)
Constructor- Parameters:
attributeName
- the name of the trace attributevalues
- the sequence of values to consider
-
-
Method Detail
-
filter
public boolean filter(BEvent t)
- Specified by:
filter
in interfaceorg.apache.flink.api.common.functions.FilterFunction<T extends Serializable>
-
-