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:
filterin interfaceorg.apache.flink.api.common.functions.FilterFunction<T extends Serializable>
-
-