Class SparkStatistics


  • public class SparkStatistics
    extends Object
    • Constructor Detail

      • SparkStatistics

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