public class Statistics extends Object
Modifier and Type | Field and Description |
---|---|
static long |
allocateDoubleArrTime |
static boolean |
allowWorkerStatistics |
static long |
examSparsityTime |
static long |
nativeConv2dBwdDataTime |
static long |
nativeConv2dBwdFilterTime |
static long |
nativeConv2dTime |
static long |
nativeLibMatrixMultTime |
static LongAdder |
numNativeConv2dBwdDataCalls |
static LongAdder |
numNativeConv2dBwdFilterCalls |
static LongAdder |
numNativeConv2dCalls |
static LongAdder |
numNativeLibMatrixMultCalls |
static LongAdder |
numNativeSparseConv2dBwdDataCalls |
static LongAdder |
numNativeSparseConv2dBwdFilterCalls |
static LongAdder |
numNativeSparseConv2dCalls |
static long |
recomputeNNZTime |
Constructor and Description |
---|
Statistics() |
Modifier and Type | Method and Description |
---|---|
static void |
accPSAggregationTime(long t) |
static void |
accPSBatchIndexingTime(long t) |
static void |
accPSGradientComputeTime(long t) |
static void |
accPSLocalModelUpdateTime(long t) |
static void |
accPSModelBroadcastTime(long t) |
static void |
accPSRpcRequestTime(long t) |
static void |
accPSSetupTime(long t) |
static void |
accSparkBroadCastTime(long t) |
static void |
accSparkCollectTime(long t) |
static void |
accSparkParallelizeTime(long t) |
static void |
addCPMemObject(int hash,
double sizeof) |
static boolean |
createdSparkContext() |
static void |
decrementNoOfExecutedSPInst() |
static String |
display()
Returns statistics of the DML program that was recently completed as a string
|
static String |
display(int maxHeavyHitters)
Returns statistics as a string
|
static long |
getCodegenClassCompile() |
static long |
getCodegenClassCompileTime() |
static long |
getCodegenCompileTime() |
static long |
getCodegenCPlanCompile() |
static long |
getCodegenDAGCompile() |
static long |
getCodegenEnumAll() |
static long |
getCodegenEnumAllP() |
static long |
getCodegenEnumEval() |
static long |
getCodegenEnumEvalP() |
static long |
getCodegenOpCacheHits() |
static long |
getCodegenOpCacheTotal() |
static long |
getCodegenPlanCacheHits() |
static long |
getCodegenPlanCacheTotal() |
static long |
getCompileTime() |
static String |
getCPHeavyHitterCode(Instruction inst) |
static long |
getCPHeavyHitterCount(String opcode) |
static Set<String> |
getCPHeavyHitterOpCodes() |
static String |
getCPHeavyHittersMem(int num) |
static long |
getFunRecompiles() |
static long |
getFunRecompileTime() |
static String |
getHeavyHitters(int num)
Obtain a string tabular representation of the heavy hitter instructions
that displays the time, instruction count, and optionally GPU stats about
each instruction.
|
static long |
getHopRecompiledPredDAGs() |
static long |
getHopRecompiledSBDAGs() |
static long |
getHopRecompileTime() |
static long |
getJITCompileTime()
Returns the total time of asynchronous JIT compilation in milliseconds.
|
static long |
getJVMgcCount() |
static long |
getJVMgcTime() |
static long |
getNoOfCompiledSPInst() |
static long |
getNoOfExecutedSPInst() |
static long |
getNumPinnedObjects() |
static long |
getParforInitTime() |
static long |
getParforMergeTime() |
static long |
getParforOptCount() |
static long |
getParforOptTime() |
static long |
getRunTime()
Returns the total time of run in nanoseconds.
|
static double |
getSizeofPinnedObjects() |
static long |
getTotalLix() |
static long |
getTotalLixUIP() |
static long |
getTotalUIPVar() |
static void |
incFederated(FederatedRequest.RequestType rqt) |
static void |
incrementCodegenClassCompile() |
static void |
incrementCodegenClassCompileTime(long delta) |
static void |
incrementCodegenCompileTime(long delta) |
static void |
incrementCodegenCPlanCompile(long delta) |
static void |
incrementCodegenDAGCompile() |
static void |
incrementCodegenEnumAll(long delta) |
static void |
incrementCodegenEnumAllP(long delta) |
static void |
incrementCodegenEnumEval(long delta) |
static void |
incrementCodegenEnumEvalP(long delta) |
static void |
incrementCodegenOpCacheHits() |
static void |
incrementCodegenOpCacheTotal() |
static void |
incrementCodegenPlanCacheHits() |
static void |
incrementCodegenPlanCacheTotal() |
static void |
incrementFunRecompiles() |
static void |
incrementFunRecompileTime(long delta) |
static void |
incrementHOPRecompilePred() |
static void |
incrementHOPRecompilePred(long delta) |
static void |
incrementHOPRecompileSB() |
static void |
incrementHOPRecompileSB(long delta) |
static void |
incrementHOPRecompileTime(long delta) |
static void |
incrementJITCompileTime(long time) |
static void |
incrementJVMgcCount(long delta) |
static void |
incrementJVMgcTime(long time) |
static void |
incrementNativeFailuresCounter() |
static void |
incrementNoOfCompiledSPInst() |
static void |
incrementNoOfExecutedSPInst() |
static void |
incrementParForInitTime(long time) |
static void |
incrementParForMergeTime(long time) |
static void |
incrementParForOptimCount() |
static void |
incrementParForOptimTime(long time) |
static void |
incrementTotalLix() |
static void |
incrementTotalLixUIP() |
static void |
incrementTotalUIPVar() |
static void |
incSparkBroadcastCount(long c) |
static void |
incSparkCollectCount(long c) |
static void |
incSparkParallelizeCount(long c) |
static void |
incWorkerNumber() |
static void |
incWorkerNumber(long n) |
static void |
maintainCPFuncCallStats(String instName) |
static void |
maintainCPHeavyHitters(String instName,
long timeNanos)
"Maintains" or adds time to per instruction/op timers, also increments associated count
|
static void |
maintainCPHeavyHittersMem(String name,
double sizeof)
Helper method which keeps track of the heaviest weight objects (by total memory used)
throughout execution of the program.
|
static void |
removeCPMemObject(int hash)
Helper method to remove a memory object which has become unpinned
|
static void |
reset() |
static void |
resetCPHeavyHitters() |
static void |
resetJITCompileTime() |
static void |
resetJVMgcCount() |
static void |
resetJVMgcTime() |
static void |
resetNoOfCompiledJobs(int count) |
static void |
resetNoOfExecutedJobs() |
static void |
setSparkCtxCreateTime(long ns) |
static void |
startCompileTimer() |
static void |
startRunTimer()
Starts the timer, should be invoked immediately before invoking
Program.execute()
|
static void |
stopCompileTimer() |
static void |
stopRunTimer()
Stops the timer, should be invoked immediately after invoking
Program.execute()
|
public static LongAdder numNativeLibMatrixMultCalls
public static LongAdder numNativeConv2dCalls
public static LongAdder numNativeConv2dBwdDataCalls
public static LongAdder numNativeConv2dBwdFilterCalls
public static LongAdder numNativeSparseConv2dCalls
public static LongAdder numNativeSparseConv2dBwdFilterCalls
public static LongAdder numNativeSparseConv2dBwdDataCalls
public static long nativeLibMatrixMultTime
public static long nativeConv2dTime
public static long nativeConv2dBwdDataTime
public static long nativeConv2dBwdFilterTime
public static long recomputeNNZTime
public static long examSparsityTime
public static long allocateDoubleArrTime
public static boolean allowWorkerStatistics
public static void incrementNativeFailuresCounter()
public static long getNoOfExecutedSPInst()
public static void incrementNoOfExecutedSPInst()
public static void decrementNoOfExecutedSPInst()
public static long getNoOfCompiledSPInst()
public static void incrementNoOfCompiledSPInst()
public static boolean createdSparkContext()
public static long getTotalUIPVar()
public static void incrementTotalUIPVar()
public static long getTotalLixUIP()
public static void incrementTotalLixUIP()
public static long getTotalLix()
public static void incrementTotalLix()
public static void resetNoOfCompiledJobs(int count)
public static void resetNoOfExecutedJobs()
public static void incrementJITCompileTime(long time)
public static void incrementJVMgcTime(long time)
public static void incrementJVMgcCount(long delta)
public static void incrementHOPRecompileTime(long delta)
public static void incrementHOPRecompilePred()
public static void incrementHOPRecompilePred(long delta)
public static void incrementHOPRecompileSB()
public static void incrementHOPRecompileSB(long delta)
public static void incrementCodegenDAGCompile()
public static void incrementCodegenCPlanCompile(long delta)
public static void incrementCodegenEnumAll(long delta)
public static void incrementCodegenEnumAllP(long delta)
public static void incrementCodegenEnumEval(long delta)
public static void incrementCodegenEnumEvalP(long delta)
public static void incrementCodegenClassCompile()
public static void incrementCodegenCompileTime(long delta)
public static void incrementCodegenClassCompileTime(long delta)
public static void incrementCodegenOpCacheHits()
public static void incrementCodegenOpCacheTotal()
public static void incrementCodegenPlanCacheHits()
public static void incrementCodegenPlanCacheTotal()
public static long getCodegenDAGCompile()
public static long getCodegenCPlanCompile()
public static long getCodegenEnumAll()
public static long getCodegenEnumAllP()
public static long getCodegenEnumEval()
public static long getCodegenEnumEvalP()
public static long getCodegenClassCompile()
public static long getCodegenCompileTime()
public static long getCodegenClassCompileTime()
public static long getCodegenOpCacheHits()
public static long getCodegenOpCacheTotal()
public static long getCodegenPlanCacheHits()
public static long getCodegenPlanCacheTotal()
public static void incrementFunRecompileTime(long delta)
public static void incrementFunRecompiles()
public static void incrementParForOptimCount()
public static void incrementParForOptimTime(long time)
public static void incrementParForInitTime(long time)
public static void incrementParForMergeTime(long time)
public static void incFederated(FederatedRequest.RequestType rqt)
public static void startCompileTimer()
public static void stopCompileTimer()
public static long getCompileTime()
public static void startRunTimer()
public static void stopRunTimer()
public static long getRunTime()
public static void reset()
public static void resetJITCompileTime()
public static void resetJVMgcTime()
public static void resetJVMgcCount()
public static void resetCPHeavyHitters()
public static void setSparkCtxCreateTime(long ns)
public static void accSparkParallelizeTime(long t)
public static void incSparkParallelizeCount(long c)
public static void accSparkCollectTime(long t)
public static void incSparkCollectCount(long c)
public static void accSparkBroadCastTime(long t)
public static void incSparkBroadcastCount(long c)
public static void incWorkerNumber()
public static void incWorkerNumber(long n)
public static void accPSSetupTime(long t)
public static void accPSGradientComputeTime(long t)
public static void accPSAggregationTime(long t)
public static void accPSLocalModelUpdateTime(long t)
public static void accPSModelBroadcastTime(long t)
public static void accPSBatchIndexingTime(long t)
public static void accPSRpcRequestTime(long t)
public static String getCPHeavyHitterCode(Instruction inst)
public static void addCPMemObject(int hash, double sizeof)
public static void removeCPMemObject(int hash)
hash
- hash of data objectpublic static void maintainCPHeavyHittersMem(String name, double sizeof)
name
- String denoting the variables namesizeof
- objects size (estimated bytes)public static void maintainCPHeavyHitters(String instName, long timeNanos)
instName
- name of the instruction/optimeNanos
- time in nano secondspublic static void maintainCPFuncCallStats(String instName)
public static long getCPHeavyHitterCount(String opcode)
public static String getHeavyHitters(int num)
num
- the maximum number of heavy hitters to displaypublic static String getCPHeavyHittersMem(int num)
public static long getJITCompileTime()
public static long getJVMgcTime()
public static long getJVMgcCount()
public static long getHopRecompileTime()
public static long getHopRecompiledPredDAGs()
public static long getHopRecompiledSBDAGs()
public static long getFunRecompileTime()
public static long getFunRecompiles()
public static long getParforOptCount()
public static long getParforOptTime()
public static long getParforInitTime()
public static long getParforMergeTime()
public static long getNumPinnedObjects()
public static double getSizeofPinnedObjects()
public static String display()
public static String display(int maxHeavyHitters)
maxHeavyHitters
- The maximum number of heavy hitters that are printedCopyright © 2020 The Apache Software Foundation. All rights reserved.