Package org.apache.spark.status

Class AppStatusUtils

Object

org.apache.spark.status.AppStatusUtils

public class AppStatusUtils
extends Object

Constructor Summary

Constructors

Constructor	Description
AppStatusUtils()

Method Summary

Modifier and Type	Method	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 java.lang.Object

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

Constructor Details

AppStatusUtils

public AppStatusUtils()

Method Details

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)