Class FederatedStatistics


  • public class FederatedStatistics
    extends Object
    • Constructor Detail

      • FederatedStatistics

        public FederatedStatistics()
    • Method Detail

      • logServerTraffic

        public static void logServerTraffic​(long read,
                                            long written)
      • logWorkerTraffic

        public static void logWorkerTraffic​(long read,
                                            long written)
      • incFedTransfer

        public static void incFedTransfer​(Object dataObj,
                                          String host)
      • incAsyncPrefetchCount

        public static void incAsyncPrefetchCount​(long c)
      • getTotalFedTransferCount

        public static long getTotalFedTransferCount()
      • reset

        public static void reset()
      • displayFedIOExecStatistics

        public static String displayFedIOExecStatistics()
      • displayNetworkTrafficStatistics

        public static String displayNetworkTrafficStatistics()
      • registerFedWorker

        public static void registerFedWorker​(String host,
                                             int port)
      • displayFedWorkers

        public static String displayFedWorkers()
      • displayFedWorkerStats

        public static String displayFedWorkerStats()
      • displayStatistics

        public static String displayStatistics​(int numHeavyHitters)
      • getFedLookupTableGetCount

        public static long getFedLookupTableGetCount()
      • getCoordinatorsTrafficBytes

        public static List<org.apache.commons.lang3.tuple.Triple<LocalDateTime,​String,​Long>> getCoordinatorsTrafficBytes()
      • getCPUUsage

        public static double getCPUUsage()
      • getMemoryUsage

        public static double getMemoryUsage()
      • getFedLookupTableGetTime

        public static long getFedLookupTableGetTime()
      • getFedLookupTableEntryCount

        public static long getFedLookupTableEntryCount()
      • getFedReuseReadHitCount

        public static long getFedReuseReadHitCount()
      • getFedReuseReadBytesCount

        public static long getFedReuseReadBytesCount()
      • getFedPutLineageCount

        public static long getFedPutLineageCount()
      • getFedPutLineageItems

        public static long getFedPutLineageItems()
      • getFedSerializationReuseCount

        public static long getFedSerializationReuseCount()
      • getFedSerializationReuseBytes

        public static long getFedSerializationReuseBytes()
      • incFedLookupTableGetCount

        public static void incFedLookupTableGetCount()
      • incFedLookupTableGetTime

        public static void incFedLookupTableGetTime​(long time)
      • incFedLookupTableEntryCount

        public static void incFedLookupTableEntryCount()
      • incFedReuseReadHitCount

        public static void incFedReuseReadHitCount()
      • incFedReuseReadBytesCount

        public static void incFedReuseReadBytesCount​(CacheableData<?> data)
      • incFedReuseReadBytesCount

        public static void incFedReuseReadBytesCount​(CacheBlock cb)
      • aggFedPutLineage

        public static void aggFedPutLineage​(String serializedLineage)
      • aggFedSerializationReuse

        public static void aggFedSerializationReuse​(long bytes)
      • displayFedLookupTableStats

        public static String displayFedLookupTableStats()
      • displayFedLookupTableStats

        public static String displayFedLookupTableStats​(long fltGetCount,
                                                        long fltEntryCount,
                                                        double fltGetTime)
      • displayFedReuseReadStats

        public static String displayFedReuseReadStats()
      • displayFedReuseReadStats

        public static String displayFedReuseReadStats​(long rrHits,
                                                      long rrBytes)
      • displayFedPutLineageStats

        public static String displayFedPutLineageStats()
      • displayFedPutLineageStats

        public static String displayFedPutLineageStats​(long plCount,
                                                       long plItems)
      • displayFedSerializationReuseStats

        public static String displayFedSerializationReuseStats()
      • displayFedSerializationReuseStats

        public static String displayFedSerializationReuseStats​(long srCount,
                                                               long srBytes)