org.apache.spark.status

Class AppStatusUtils

Object

org.apache.spark.status.AppStatusUtils

public class AppStatusUtils
extends Object

Constructor Summary

Constructors

Constructor and Description
AppStatusUtils()

Method Summary

Modifier and Type	Method and Description
static scala.collection.IndexedSeq<Object>	getQuantilesValue(scala.collection.IndexedSeq<Object> values, double[] quantiles)
static long	gettingResultTime(long launchTime, long fetchStart, long duration)
static long	gettingResultTime(TaskData task)
static long	schedulerDelay(long launchTime, long fetchStart, long duration, long deserializeTime, long serializeTime, long runTime)
static long	schedulerDelay(TaskData task)

Methods inherited from class Object

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

Constructor Detail

AppStatusUtils

public AppStatusUtils()

Method Detail

schedulerDelay

public static long schedulerDelay(TaskData task)

gettingResultTime

public static long gettingResultTime(TaskData task)

schedulerDelay

public static long schedulerDelay(long launchTime,
                                  long fetchStart,
                                  long duration,
                                  long deserializeTime,
                                  long serializeTime,
                                  long runTime)

gettingResultTime

public static long gettingResultTime(long launchTime,
                                     long fetchStart,
                                     long duration)

getQuantilesValue

public static scala.collection.IndexedSeq<Object> getQuantilesValue(scala.collection.IndexedSeq<Object> values,
                                                                    double[] quantiles)