Package org.apache.nemo.runtime.executor

Class MetricManagerWorker

  • All Implemented Interfaces:
    java.lang.AutoCloseable, MetricMessageSender
    public final class MetricManagerWorker
extends java.lang.Object
implements MetricMessageSender
    Metric sender that periodically flushes the collected metrics to Driver.

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void close()
      Flush the metric queue and close the metric dispatch.
      void flush()
      Flush all metric inside of the queue.
      void send​(java.lang.String metricType, java.lang.String metricId, java.lang.String metricField, byte[] metricValue)
      Send metric to master.

      • Methods inherited from class java.lang.Object

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

    • Method Detail

      • send

        public void send​(java.lang.String metricType,
                 java.lang.String metricId,
                 java.lang.String metricField,
                 byte[] metricValue)
        Description copied from interface: MetricMessageSender
        Send metric to master.
        Specified by:
        send in interface MetricMessageSender
        Parameters:
        metricType - type of the metric
        metricId - id of the metric
        metricField - field of the metric
        metricValue - value of the metric which is serialized

      • close

        public void close()
        Description copied from interface: MetricMessageSender
        Flush the metric queue and close the metric dispatch.
        Specified by:
        close in interface java.lang.AutoCloseable
        Specified by:
        close in interface MetricMessageSender