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

Class JetMetricsContainer

  • All Implemented Interfaces:
    java.io.Serializable, org.apache.beam.sdk.metrics.MetricsContainer
    public class JetMetricsContainer
extends java.lang.Object
implements org.apache.beam.sdk.metrics.MetricsContainer
    Jet specific implementation of MetricsContainer.
    See Also:
    Serialized Form

    • Constructor Summary

      Constructors 
      Constructor Description
      JetMetricsContainer​(java.lang.String stepName, java.lang.String ownerId, com.hazelcast.jet.core.Processor.Context context)  

    • Method Summary

      All Methods Static Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void flush​(boolean async)  
      org.apache.beam.sdk.metrics.BoundedTrie getBoundedTrie​(org.apache.beam.sdk.metrics.MetricName metricName)  
      org.apache.beam.sdk.metrics.Counter getCounter​(org.apache.beam.sdk.metrics.MetricName metricName)  
      org.apache.beam.sdk.metrics.Distribution getDistribution​(org.apache.beam.sdk.metrics.MetricName metricName)  
      org.apache.beam.sdk.metrics.Gauge getGauge​(org.apache.beam.sdk.metrics.MetricName metricName)  
      static java.lang.String getMetricsMapName​(long jobId)  
      org.apache.beam.sdk.metrics.StringSet getStringSet​(org.apache.beam.sdk.metrics.MetricName metricName)  

      • Methods inherited from class java.lang.Object

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

      • Methods inherited from interface org.apache.beam.sdk.metrics.MetricsContainer

        getHistogram, getMonitoringInfos, getPerWorkerCounter

    • Constructor Detail

      • JetMetricsContainer

        public JetMetricsContainer​(java.lang.String stepName,
                           java.lang.String ownerId,
                           com.hazelcast.jet.core.Processor.Context context)

    • Method Detail

      • getMetricsMapName

        public static java.lang.String getMetricsMapName​(long jobId)

      • getCounter

        public org.apache.beam.sdk.metrics.Counter getCounter​(org.apache.beam.sdk.metrics.MetricName metricName)
        Specified by:
        getCounter in interface org.apache.beam.sdk.metrics.MetricsContainer

      • getDistribution

        public org.apache.beam.sdk.metrics.Distribution getDistribution​(org.apache.beam.sdk.metrics.MetricName metricName)
        Specified by:
        getDistribution in interface org.apache.beam.sdk.metrics.MetricsContainer

      • getGauge

        public org.apache.beam.sdk.metrics.Gauge getGauge​(org.apache.beam.sdk.metrics.MetricName metricName)
        Specified by:
        getGauge in interface org.apache.beam.sdk.metrics.MetricsContainer

      • getStringSet

        public org.apache.beam.sdk.metrics.StringSet getStringSet​(org.apache.beam.sdk.metrics.MetricName metricName)
        Specified by:
        getStringSet in interface org.apache.beam.sdk.metrics.MetricsContainer

      • getBoundedTrie

        public org.apache.beam.sdk.metrics.BoundedTrie getBoundedTrie​(org.apache.beam.sdk.metrics.MetricName metricName)
        Specified by:
        getBoundedTrie in interface org.apache.beam.sdk.metrics.MetricsContainer

      • flush

        public void flush​(boolean async)