Package | Description |
---|---|
com.hazelcast.jet |
Hazelcast Jet is a distributed computation engine running on top of
Hazelcast IMDG technology.
|
com.hazelcast.jet.core.metrics |
Jet's Job Metric API.
|
Modifier and Type | Method and Description |
---|---|
JobMetrics |
Job.getMetrics()
Returns a snapshot of the current values of all job-specific metrics.
|
Modifier and Type | Method and Description |
---|---|
static JobMetrics |
JobMetrics.empty()
Returns an empty
JobMetrics object. |
JobMetrics |
JobMetrics.filter(Predicate<Measurement> predicate)
Returns a new
JobMetrics instance containing a subset of
the Measurement s found in the current one. |
JobMetrics |
JobMetrics.filter(String tagName,
String tagValue)
Convenience method for
#filter(Predicate ,
returns a new JobMetrics instance containing only those
Measurement s which have the specified tag set to the
specified value. |
static JobMetrics |
JobMetrics.of(Stream<Measurement> measurements)
Builds a
JobMetrics object based on a stream of
Measurement s. |
Copyright © 2019 Hazelcast, Inc.. All rights reserved.