[systemds] branch main updated: [MINOR] Fix Local Federated data

[baunsgaard]

This is an automated email from the ASF dual-hosted git repository.

baunsgaard pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/systemds.git


The following commit(s) were added to refs/heads/main by this push:
     new 148de1b564 [MINOR] Fix Local Federated data
148de1b564 is described below

commit 148de1b56452b159a982ac147c9f4a4357b345d7
Author: baunsgaard <baunsga...@tugraz.at>
AuthorDate: Thu Apr 28 15:03:47 2022 +0200

    [MINOR] Fix Local Federated data
---
 .../controlprogram/federated/FederatedLocalData.java  | 19 ++++++++++---------
 1 file changed, 10 insertions(+), 9 deletions(-)

diff --git 
a/src/main/java/org/apache/sysds/runtime/controlprogram/federated/FederatedLocalData.java
 
b/src/main/java/org/apache/sysds/runtime/controlprogram/federated/FederatedLocalData.java
index 90fed5c84e..de56a1a52e 100644
--- 
a/src/main/java/org/apache/sysds/runtime/controlprogram/federated/FederatedLocalData.java
+++ 
b/src/main/java/org/apache/sysds/runtime/controlprogram/federated/FederatedLocalData.java
@@ -30,21 +30,15 @@ import 
org.apache.sysds.runtime.controlprogram.parfor.util.IDHandler;
 public class FederatedLocalData extends FederatedData {
        protected final static Logger log = 
Logger.getLogger(FederatedWorkerHandler.class);
 
-       private final FederatedLookupTable _flt;
-       private final FederatedReadCache _frc;
-       private final FederatedWorkloadAnalyzer _fan;
+       private static final FederatedLookupTable _flt = new 
FederatedLookupTable();
+       private static final FederatedReadCache _frc = new FederatedReadCache();
+       private static final FederatedWorkloadAnalyzer _fan = initAnalyzer();
        private final FederatedWorkerHandler _fwh;
 
        private final CacheableData<?> _data;
 
        public FederatedLocalData(long id, CacheableData<?> data) {
                super(data.getDataType(), null, data.getFileName());
-               _flt = new FederatedLookupTable();
-               _frc = new FederatedReadCache();
-               if(ConfigurationManager.getCompressConfig().isWorkload())
-                       _fan = new FederatedWorkloadAnalyzer();
-               else
-                       _fan = null;
                _fwh = new FederatedWorkerHandler(_flt, _frc, _fan);
 
                _data = data;
@@ -56,6 +50,13 @@ public class FederatedLocalData extends FederatedData {
                setVarID(id);
        }
 
+       private static FederatedWorkloadAnalyzer initAnalyzer() {
+               if(ConfigurationManager.getCompressConfig().isWorkload())
+                       return new FederatedWorkloadAnalyzer();
+               else
+                       return null;
+       }
+
        @Override
        boolean equalAddress(FederatedData that) {
                return that.getClass().equals(this.getClass());