Class RetainOnCaseAttributeEqualityFilter<T extends Serializable>

  • 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 Detail

      • RetainOnCaseAttributeEqualityFilter

        @SafeVarargs
        public RetainOnCaseAttributeEqualityFilter​(String attributeName,
                                                   T... values)
        Constructor
        Parameters:
        attributeName - the name of the trace attribute
        values - the sequence of values to consider
    • Method Detail

      • filter

        public boolean filter​(BEvent t)
        Specified by:
        filter in interface org.apache.flink.api.common.functions.FilterFunction<T extends Serializable>