Package beamline.filters

Class RetainOnEventAttributeEqualityFilter<T extends Serializable>

java.lang.Object

beamline.filters.RetainOnEventAttributeEqualityFilter<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:

RetainActivitiesFilter

public class RetainOnEventAttributeEqualityFilter<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 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 retain the event).

Author:

Andrea Burattin

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
RetainOnEventAttributeEqualityFilter(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 retention
boolean	filter(BEvent event)

Methods inherited from class java.lang.Object

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

Constructor Detail

RetainOnEventAttributeEqualityFilter

@SafeVarargs
public RetainOnEventAttributeEqualityFilter(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 retention

Parameters:

value - value

filter

public boolean filter(BEvent event)

Specified by:

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