Class MeasurementPredicates

java.lang.Object
com.hazelcast.jet.core.metrics.MeasurementPredicates

public final class MeasurementPredicates extends Object
Static utility class for creating various Measurement filtering predicates.
Since:
Jet 3.2
  • Method Details

    • containsTag

      public static Predicate<Measurement> containsTag(String tag)
      Matches a Measurement which contain the specified tag.
      Parameters:
      tag - the tag of interest
      Returns:
      a filtering predicate
    • tagValueEquals

      public static Predicate<Measurement> tagValueEquals(String tag, String value)
      Matches a Measurement which contains the specified tag and the tag has the specified value.
      Parameters:
      tag - the tag to match
      value - the value the tag has to have
      Returns:
      a filtering predicate
    • tagValueMatches

      public static Predicate<Measurement> tagValueMatches(String tag, String valueRegexp)
      Matches a Measurement which has this exact tag with a value matching the provided regular expression.
      Parameters:
      tag - the tag to match
      valueRegexp - regular expression to match the value against
      Returns:
      a filtering predicate