Package beamline.filters

Class ExcludeOnEventAttributeEqualityFilter<T extends Serializable>

java.lang.Object

beamline.filters.ExcludeOnEventAttributeEqualityFilter<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

Direct Known Subclasses:

ExcludeActivitiesFilter

public class ExcludeOnEventAttributeEqualityFilter<T extends Serializable>
extends Object
implements org.apache.flink.api.common.functions.FilterFunction<BEvent>

This filter excludes events based on the equality of a certain event 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 discard the event).

Author:

Andrea Burattin

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
ExcludeOnEventAttributeEqualityFilter(String attributeName, T... values)	Constructor

Method Summary

Modifier and Type	Method	Description
void	addValue(T value)	Adds the value to the list of values to be considered for removal
boolean	filter(BEvent t)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ExcludeOnEventAttributeEqualityFilter

@SafeVarargs
public ExcludeOnEventAttributeEqualityFilter(String attributeName,
                                             T... values)

Constructor

Parameters:

attributeName - the name of the event attribute

values - the sequence of values to consider

Method Detail

addValue

public void addValue(T value)

Adds the value to the list of values to be considered for removal

Parameters:

value - value

filter

public boolean filter(BEvent t)

Specified by:

filter in interface org.apache.flink.api.common.functions.FilterFunction<T extends Serializable>