Class FederatedStatistics
- java.lang.Object
- 
- org.apache.sysds.runtime.controlprogram.federated.FederatedStatistics
 
- 
 public class FederatedStatistics extends Object 
- 
- 
Nested Class SummaryNested Classes Modifier and Type Class Description static classFederatedStatistics.FedStatsCollectFunctionstatic classFederatedStatistics.FedStatsCollection
 - 
Constructor SummaryConstructors Constructor Description FederatedStatistics()
 - 
Method Summary
 
- 
- 
- 
Method Detail- 
logServerTrafficpublic static void logServerTraffic(long read, long written)
 - 
logWorkerTrafficpublic static void logWorkerTraffic(long read, long written)
 - 
incFederatedpublic static void incFederated(FederatedRequest.RequestType rqt, List<Object> data) 
 - 
incAsyncPrefetchCountpublic static void incAsyncPrefetchCount(long c) 
 - 
getTotalFedTransferCountpublic static long getTotalFedTransferCount() 
 - 
resetpublic static void reset() 
 - 
displayFedIOExecStatisticspublic static String displayFedIOExecStatistics() 
 - 
displayNetworkTrafficStatisticspublic static String displayNetworkTrafficStatistics() 
 - 
registerFedWorkerpublic static void registerFedWorker(String host, int port) 
 - 
displayFedWorkerspublic static String displayFedWorkers() 
 - 
displayFedWorkerStatspublic static String displayFedWorkerStats() 
 - 
displayStatisticspublic static String displayStatistics(int numHeavyHitters) 
 - 
displayStatisticspublic static String displayStatistics(FederatedStatistics.FedStatsCollection fedStats, int numHeavyHitters) 
 - 
getFedLookupTableGetCountpublic static long getFedLookupTableGetCount() 
 - 
getCoordinatorsTrafficBytespublic static List<org.apache.commons.lang3.tuple.Triple<LocalDateTime,String,Long>> getCoordinatorsTrafficBytes() 
 - 
getCPUUsagepublic static double getCPUUsage() 
 - 
getMemoryUsagepublic static double getMemoryUsage() 
 - 
getFedLookupTableGetTimepublic static long getFedLookupTableGetTime() 
 - 
getFedLookupTableEntryCountpublic static long getFedLookupTableEntryCount() 
 - 
getFedReuseReadHitCountpublic static long getFedReuseReadHitCount() 
 - 
getFedReuseReadBytesCountpublic static long getFedReuseReadBytesCount() 
 - 
getFedPutLineageCountpublic static long getFedPutLineageCount() 
 - 
getFedPutLineageItemspublic static long getFedPutLineageItems() 
 - 
getFedSerializationReuseCountpublic static long getFedSerializationReuseCount() 
 - 
getFedSerializationReuseBytespublic static long getFedSerializationReuseBytes() 
 - 
incFedLookupTableGetCountpublic static void incFedLookupTableGetCount() 
 - 
incFedLookupTableGetTimepublic static void incFedLookupTableGetTime(long time) 
 - 
incFedLookupTableEntryCountpublic static void incFedLookupTableEntryCount() 
 - 
incFedReuseReadHitCountpublic static void incFedReuseReadHitCount() 
 - 
incFedReuseReadBytesCountpublic static void incFedReuseReadBytesCount(CacheableData<?> data) 
 - 
incFedReuseReadBytesCountpublic static void incFedReuseReadBytesCount(CacheBlock cb) 
 - 
aggFedPutLineagepublic static void aggFedPutLineage(String serializedLineage) 
 - 
aggFedSerializationReusepublic static void aggFedSerializationReuse(long bytes) 
 - 
displayFedLookupTableStatspublic static String displayFedLookupTableStats() 
 - 
displayFedLookupTableStatspublic static String displayFedLookupTableStats(long fltGetCount, long fltEntryCount, double fltGetTime) 
 - 
displayFedReuseReadStatspublic static String displayFedReuseReadStats() 
 - 
displayFedReuseReadStatspublic static String displayFedReuseReadStats(long rrHits, long rrBytes) 
 - 
displayFedPutLineageStatspublic static String displayFedPutLineageStats() 
 - 
displayFedPutLineageStatspublic static String displayFedPutLineageStats(long plCount, long plItems) 
 - 
displayFedSerializationReuseStatspublic static String displayFedSerializationReuseStats() 
 - 
displayFedSerializationReuseStatspublic static String displayFedSerializationReuseStats(long srCount, long srBytes) 
 
- 
 
-