sampled all

Baunsgaard · Baunsgaard · commit 9bf572f09246 · 2025-01-13T23:38:38.000+01:00
diff --git a/src/main/java/org/apache/sysds/runtime/frame/data/compress/CompressedFrameBlockFactory.java b/src/main/java/org/apache/sysds/runtime/frame/data/compress/CompressedFrameBlockFactory.java
@@ -208,7 +208,7 @@ private Array<?> compressColFinally(int i, final Array<?> a, final ArrayCompress
 		Timing time = LOG.isDebugEnabled() ? new Timing(true) : null;
 		if(s.bestType != null && s.shouldCompress) {
 			if(s.bestType == FrameArrayType.DDC)
-				compressedColumns[i] = DDCArray.compressToDDC(a);
+				compressedColumns[i] = DDCArray.compressToDDC(a, s.sampledAllRows ? s.nUnique : Integer.MAX_VALUE);
 			else
 				throw new RuntimeException("Unsupported frame compression encoding : " + s.bestType);
 		}

Original file line number	Diff line number	Diff line change
`@@ -208,7 +208,7 @@ private Array<?> compressColFinally(int i, final Array<?> a, final ArrayCompress`
`208`	`208`	`Timing time = LOG.isDebugEnabled() ? new Timing(true) : null;`
`209`	`209`	`if(s.bestType != null && s.shouldCompress) {`
`210`	`210`	`if(s.bestType == FrameArrayType.DDC)`
`211`		`- compressedColumns[i] = DDCArray.compressToDDC(a);`
	`211`	`+ compressedColumns[i] = DDCArray.compressToDDC(a, s.sampledAllRows ? s.nUnique : Integer.MAX_VALUE);`
`212`	`212`	`else`
`213`	`213`	`throw new RuntimeException("Unsupported frame compression encoding : " + s.bestType);`
`214`	`214`	`}`