Package org.apache.sysds.utils.stats
Class SparkStatistics
- java.lang.Object
-
- org.apache.sysds.utils.stats.SparkStatistics
-
public class SparkStatistics extends Object
-
-
Constructor Summary
Constructors Constructor Description SparkStatistics()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static voidaccBroadCastTime(long t)static voidaccCollectTime(long t)static voidaccParallelizeTime(long t)static booleancreatedSparkContext()static StringdisplayStatistics()static longgetAsyncBroadcastCount()static longgetAsyncPrefetchCount()static longgetAsyncSparkOpCount()static longgetasyncTriggerCheckpointCount()static longgetSparkCollectCount()static voidincAsyncBroadcastCount(long c)static voidincAsyncPrefetchCount(long c)static voidincAsyncSparkOpCount(long c)static voidincAsyncTriggerCheckpointCount(long c)static voidincBroadcastCount(long c)static voidincParallelizeCount(long c)static voidreset()static voidsetCtxCreateTime(long ns)
-
-
-
Method Detail
-
createdSparkContext
public static boolean createdSparkContext()
-
setCtxCreateTime
public static void setCtxCreateTime(long ns)
-
accParallelizeTime
public static void accParallelizeTime(long t)
-
incParallelizeCount
public static void incParallelizeCount(long c)
-
accCollectTime
public static void accCollectTime(long t)
-
accBroadCastTime
public static void accBroadCastTime(long t)
-
incBroadcastCount
public static void incBroadcastCount(long c)
-
incAsyncPrefetchCount
public static void incAsyncPrefetchCount(long c)
-
incAsyncBroadcastCount
public static void incAsyncBroadcastCount(long c)
-
incAsyncTriggerCheckpointCount
public static void incAsyncTriggerCheckpointCount(long c)
-
incAsyncSparkOpCount
public static void incAsyncSparkOpCount(long c)
-
getSparkCollectCount
public static long getSparkCollectCount()
-
getAsyncPrefetchCount
public static long getAsyncPrefetchCount()
-
getAsyncSparkOpCount
public static long getAsyncSparkOpCount()
-
getAsyncBroadcastCount
public static long getAsyncBroadcastCount()
-
getasyncTriggerCheckpointCount
public static long getasyncTriggerCheckpointCount()
-
reset
public static void reset()
-
displayStatistics
public static String displayStatistics()
-
-