Package org.apache.sysds.utils.stats

Class SparkStatistics

java.lang.Object
org.apache.sysds.utils.stats.SparkStatistics
public class SparkStatistics extends Object

  • Constructor Details

    • SparkStatistics

      public SparkStatistics()

  • Method Details

    • 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()

    • anyAsyncOp

      public static boolean anyAsyncOp()

    • displayStatistics

      public static String displayStatistics()

    • displayAsyncStats

      public static String displayAsyncStats()