io.confluent.telemetry.config

Class FilterSetPredicate

java.lang.Object

io.confluent.telemetry.config.FilterSetPredicate

All Implemented Interfaces:

Predicate<Keyed>

public class FilterSetPredicate
extends Object
implements Predicate<Keyed>

A grouping of unique NamedPredicates to be applied to an Exporter. For ease of usage, it provides a Predicate interface, which operates as a logical OR of all filters in this set. It also provides set-like operation to merge FilterSetPredicate and extract a subset of it. For the scope of this class, a NamedPredicate is identified only by its name.

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
static FilterSetPredicate	fromNamedFilter(io.confluent.telemetry.config.v2.NamedFilter filter)
static FilterSetPredicate	fromNamedFilter(Set<io.confluent.telemetry.config.v2.NamedFilter> filters)
int	hashCode()
FilterSetPredicate	subset(Set<String> filterNames) Returns a new FilterSetPredicate containing only the NamedFilters with the given names.
boolean	test(Keyed key) We avoid the streams abstraction here for performance reasons since this will be called on every metric for every predicate.
FilterSetPredicate	union(FilterSetPredicate other) Creates a new FilterSetPredicate containing all the NamedFilters from this object, plus any NamedFilters from the other set that is not contained the current NamedFilterSet.

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.util.function.Predicate

and, isEqual, negate, or

Method Detail

fromNamedFilter

public static FilterSetPredicate fromNamedFilter(io.confluent.telemetry.config.v2.NamedFilter filter)

fromNamedFilter

public static FilterSetPredicate fromNamedFilter(Set<io.confluent.telemetry.config.v2.NamedFilter> filters)

subset

public FilterSetPredicate subset(Set<String> filterNames)

Returns a new FilterSetPredicate containing only the NamedFilters with the given names. It throws a NoSuchElementException if the filterNames contains any name that isn't defined in this FilterSetPredicate

union

public FilterSetPredicate union(FilterSetPredicate other)

Creates a new FilterSetPredicate containing all the NamedFilters from this object, plus any NamedFilters from the other set that is not contained the current NamedFilterSet.

test

public boolean test(Keyed key)

We avoid the streams abstraction here for performance reasons since this will be called on every metric for every predicate.

Specified by:

test in interface Predicate<Keyed>

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object