Package org.apache.beam.runners.jet.metrics

Class JetMetricResults

  • public class JetMetricResults
extends org.apache.beam.sdk.metrics.MetricResults
    Jet specific MetricResults.

    • Constructor Summary

      Constructors 
      Constructor Description
      JetMetricResults​(com.hazelcast.map.IMap<java.lang.String,​org.apache.beam.runners.core.metrics.MetricUpdates> metricsAccumulator)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void freeze()  
      org.apache.beam.sdk.metrics.MetricQueryResults queryMetrics​(@Nullable org.apache.beam.sdk.metrics.MetricsFilter filter)  

      • Methods inherited from class org.apache.beam.sdk.metrics.MetricResults

        allMetrics, toString

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • JetMetricResults

        public JetMetricResults​(com.hazelcast.map.IMap<java.lang.String,​org.apache.beam.runners.core.metrics.MetricUpdates> metricsAccumulator)

    • Method Detail

      • freeze

        public void freeze()

      • queryMetrics

        public org.apache.beam.sdk.metrics.MetricQueryResults queryMetrics​(@Nullable org.apache.beam.sdk.metrics.MetricsFilter filter)
        Specified by:
        queryMetrics in class org.apache.beam.sdk.metrics.MetricResults