co.cask.cdap.proto

Class WorkflowStatistics

java.lang.Object

co.cask.cdap.proto.WorkflowStatistics

public class WorkflowStatistics
extends Object

Class that is used to return the statistics of a workflow

Constructor Summary

Constructors

Constructor and Description
WorkflowStatistics(long startTime, long endTime, int runs, double avgRunTime, List<PercentileInformation> percentileInformationList, Map<String,Map<String,String>> nodes)

Method Summary

Methods

Modifier and Type	Method and Description
double	getAvgRunTime()
long	getEndTime()
Map<String,Map<String,String>>	getNodes() Sample response of getNodes
List<PercentileInformation>	getPercentileInformationList()
int	getRuns()
long	getStartTime()

Methods inherited from class java.lang.Object

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

Constructor Detail

WorkflowStatistics

public WorkflowStatistics(long startTime,
                  long endTime,
                  int runs,
                  double avgRunTime,
                  List<PercentileInformation> percentileInformationList,
                  Map<String,Map<String,String>> nodes)

Method Detail

getPercentileInformationList

public List<PercentileInformation> getPercentileInformationList()

getRuns

public int getRuns()

getAvgRunTime

public double getAvgRunTime()

getStartTime

public long getStartTime()

getEndTime

public long getEndTime()

getNodes

public Map<String,Map<String,String>> getNodes()

Sample response of getNodes

Returns:

{"FirstMapReduceProgram":{"avgRunTime":"3.6666666666666665", "88.6":"4","95.0":"4","runs":"3","type":"MapReduce"}, "FirstSparkProgram":{"avgRunTime":"3.5", "70.0":"4","95.0":"5","runs":"10","type":"Spark"}}