Package | Description |
---|---|
com.hazelcast.jet.core.metrics |
Jet's Job Metric API.
|
Modifier and Type | Method and Description |
---|---|
static Measurement |
Measurement.of(String metric,
long value,
long timestamp,
Map<String,String> tags)
Builds a
Measurement instance based on timestamp, value and
the metric descriptor in map form. |
Modifier and Type | Method and Description |
---|---|
static Predicate<Measurement> |
MeasurementPredicates.containsTag(String tag)
Matches a
Measurement which contain the specified tag. |
List<Measurement> |
JobMetrics.get(String metricName)
Returns all
Measurement s associated with a given metric name. |
static Predicate<Measurement> |
MeasurementPredicates.tagValueEquals(String tag,
String value)
Matches a
Measurement which contains the specified tag and
the tag has the specified value. |
static Predicate<Measurement> |
MeasurementPredicates.tagValueMatches(String tag,
String valueRegexp)
Matches a
Measurement which has this exact tag with a value
matching the provided regular expression. |
Modifier and Type | Method and Description |
---|---|
JobMetrics |
JobMetrics.filter(Predicate<Measurement> predicate)
Returns a new
JobMetrics instance containing a subset of
the Measurement s found in the current one. |
static JobMetrics |
JobMetrics.of(Map<String,List<Measurement>> metrics)
Builds a
JobMetrics object based on a map of
Measurement s. |
Copyright © 2021 Hazelcast, Inc.. All rights reserved.