[SYSTEMDS-335] Rename lineage cache eviction policies
This patch renames WEIGHTED policy to COSTNSIZE.
diff --git a/src/main/java/org/apache/sysds/api/DMLOptions.java b/src/main/java/org/apache/sysds/api/DMLOptions.java
index 5d8b360..fe95510 100644
--- a/src/main/java/org/apache/sysds/api/DMLOptions.java
+++ b/src/main/java/org/apache/sysds/api/DMLOptions.java
@@ -132,7 +132,7 @@
else if (lineageType.equalsIgnoreCase("policy_lru"))
dmlOptions.linCachePolicy = LineageCachePolicy.LRU;
else if (lineageType.equalsIgnoreCase("policy_weighted"))
- dmlOptions.linCachePolicy = LineageCachePolicy.WEIGHTED;
+ dmlOptions.linCachePolicy = LineageCachePolicy.COSTNSIZE;
else if (lineageType.equalsIgnoreCase("policy_hybrid"))
dmlOptions.linCachePolicy = LineageCachePolicy.HYBRID;
else
diff --git a/src/main/java/org/apache/sysds/runtime/lineage/LineageCacheConfig.java b/src/main/java/org/apache/sysds/runtime/lineage/LineageCacheConfig.java
index 924c5f2..f17e055 100644
--- a/src/main/java/org/apache/sysds/runtime/lineage/LineageCacheConfig.java
+++ b/src/main/java/org/apache/sysds/runtime/lineage/LineageCacheConfig.java
@@ -116,7 +116,7 @@
public enum LineageCachePolicy {
LRU,
- WEIGHTED,
+ COSTNSIZE,
HYBRID;
}
@@ -219,7 +219,7 @@
case LRU:
WEIGHTS[0] = 0; WEIGHTS[1] = 1;
break;
- case WEIGHTED:
+ case COSTNSIZE:
WEIGHTS[0] = 1; WEIGHTS[1] = 0;
break;
case HYBRID:
diff --git a/src/test/java/org/apache/sysds/test/functions/lineage/CacheEvictionTest.java b/src/test/java/org/apache/sysds/test/functions/lineage/CacheEvictionTest.java
index 417d0a9..dd8d4d8 100644
--- a/src/test/java/org/apache/sysds/test/functions/lineage/CacheEvictionTest.java
+++ b/src/test/java/org/apache/sysds/test/functions/lineage/CacheEvictionTest.java
@@ -103,19 +103,19 @@
long hitCount_lru = LineageCacheStatistics.getInstHits();
long evictedCount_lru = LineageCacheStatistics.getMemDeletes();
- // Weighted scheme (computationTime/Size)
+ // costnsize scheme (computationTime/Size)
proArgs.clear();
proArgs.add("-stats");
proArgs.add("-lineage");
proArgs.add(ReuseCacheType.REUSE_FULL.name().toLowerCase());
- proArgs.add("policy_weighted");
+ proArgs.add("policy_costnsize");
proArgs.add("-args");
proArgs.add(String.valueOf(cacheSize));
proArgs.add(output("R"));
programArgs = proArgs.toArray(new String[proArgs.size()]);
Lineage.resetInternalState();
runTest(true, EXCEPTION_NOT_EXPECTED, null, -1);
- HashMap<MatrixValue.CellIndex, Double> R_weighted= readDMLMatrixFromHDFS("R");
+ HashMap<MatrixValue.CellIndex, Double> R_costnsize= readDMLMatrixFromHDFS("R");
long expCount_wt = Statistics.getCPHeavyHitterCount("exp");
long hitCount_wt = LineageCacheStatistics.getInstHits();
long evictedCount_wt = LineageCacheStatistics.getMemDeletes();
@@ -123,7 +123,7 @@
// Compare results
Lineage.setLinReuseNone();
- TestUtils.compareMatrices(R_lru, R_weighted, 1e-6, "LRU", "Weighted");
+ TestUtils.compareMatrices(R_lru, R_costnsize, 1e-6, "LRU", "costnsize");
// Compare reused instructions
Assert.assertTrue(expCount_lru > expCount_wt);
