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

[ba...@apache.org]

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 <ba...@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());