Class TaskMetric

    • Constructor Detail

      • TaskMetric

        public TaskMetric​(java.lang.String id)
    • Method Detail

      • getContainerId

        public final java.lang.String getContainerId()
        Method related to container Id.
      • getScheduleAttempt

        public final int getScheduleAttempt()
        Method related to schedule attempt.
      • getTaskDuration

        public final long getTaskDuration()
        Method related to task duration.
      • getStreamMetric

        public final java.util.Map<java.lang.String,​java.util.List<StreamMetric>> getStreamMetric()
        Method related to stream metric.
        the streamMetrics
      • getLatencyMetric

        public final java.util.Map<java.lang.String,​java.util.List<LatencyMetric>> getLatencyMetric()
      • getTaskCPUTime

        public final long getTaskCPUTime()
        Method related to task CPU time.
      • getSchedulingOverhead

        public final long getSchedulingOverhead()
        Method related to scheduling overhead.
      • getSerializedReadBytes

        public final long getSerializedReadBytes()
        Method related to serialized read bytes. serialized = encoded + compressed
      • getEncodedReadBytes

        public final long getEncodedReadBytes()
        Method related to encoded read bytes.
      • getTaskOutputBytes

        public final long getTaskOutputBytes()
        Method related to task output bytes.
      • getTaskSerializationTime

        public final long getTaskSerializationTime()
        Method related to task serialization time.
      • getTaskDeserializationTime

        public final long getTaskDeserializationTime()
        Method related to task deserialization time.
      • getBoundedSourceReadTime

        public final long getBoundedSourceReadTime()
        Method related to bounded source read time.
      • getPeakExecutionMemory

        public final long getPeakExecutionMemory()
        Method related to peak execution memory.
      • getTaskSizeRatio

        public final int getTaskSizeRatio()
        Method related to task size ratio.
      • getShuffleReadBytes

        public final long getShuffleReadBytes()
        Method related to shuffle.
      • getShuffleReadTime

        public final long getShuffleReadTime()
      • getShuffleWriteBytes

        public final long getShuffleWriteBytes()
      • getShuffleWriteTime

        public final long getShuffleWriteTime()
      • getId

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

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