Package org.apache.nemo.runtime.executor

Interface MetricMessageSender

  • All Superinterfaces:
    java.lang.AutoCloseable
    All Known Implementing Classes:
    MetricManagerWorker
    @DefaultImplementation(MetricManagerWorker.class)
public interface MetricMessageSender
extends java.lang.AutoCloseable
    Interface for metric sender.

    • Method Summary

      All Methods Instance Methods Abstract 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.

    • Method Detail

      • send

        void send​(java.lang.String metricType,
          java.lang.String metricId,
          java.lang.String metricField,
          byte[] metricValue)
        Send metric to master.
        Parameters:
        metricType - type of the metric
        metricId - id of the metric
        metricField - field of the metric
        metricValue - value of the metric which is serialized

      • flush

        void flush()
        Flush all metric inside of the queue.

      • close

        void close()
        Flush the metric queue and close the metric dispatch.
        Specified by:
        close in interface java.lang.AutoCloseable