Class TaskMetric

    • Constructor Detail

      • TaskMetric

        public TaskMetric​(String id)
    • Method Detail

      • getSerializedReadBytes

        public final long getSerializedReadBytes()
      • getEncodedReadBytes

        public final long getEncodedReadBytes()
      • getBoundedSourceReadTime

        public final long getBoundedSourceReadTime()
      • getTaskDeserializationTime

        public final long getTaskDeserializationTime()
      • getWrittenBytes

        public final long getWrittenBytes()
      • getScheduleAttempt

        public final int getScheduleAttempt()
      • getContainerId

        public final String getContainerId()
      • getId

        public final String getId()
        Description copied from interface: Metric
        Get its unique id.
        Specified by:
        getId in interface Metric
        Returns:
        an unique id
      • processMetricMessage

        public final boolean processMetricMessage​(String metricField,
                                                  byte[] metricValue)
        Description copied from interface: Metric
        Process metric message from evaluators.
        Specified by:
        processMetricMessage in interface Metric
        Parameters:
        metricField - field name of the metric.
        metricValue - byte array of serialized data value.
        Returns:
        true if the metric was changed or false if not.