info

Baunsgaard · Oct 21, 2024 · ccba531 · ccba531
1 parent 433dba0
commit ccba531
Showing 1 changed file with 6 additions and 4 deletions.
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
@@ -140,6 +140,7 @@ private Array<?> compressColFinally(int i, Future<Array<?>> f) throws Exception
 	private Array<?> allocateCorrectedType(int i) {
 		final ArrayCompressionStatistics s = stats[i];
 		final Array<?> a = in.getColumn(i);
+
 		if(s.valueType != a.getValueType())
 			return ArrayFactory.allocate(s.valueType, a.size(), s.containsNull);
 		else
@@ -226,11 +227,12 @@ private void logStatistics() {
 			for(int i = 0; i < compressedColumns.length; i++) {
 				if(in.getColumn(i) instanceof ACompressedArray)
 					sb.append(String.format("Col: %3d, %s\n", i, "Column is already compressed"));
-				else if(stats[i].shouldCompress)
-					sb.append(String.format("Col: %3d, %s\n", i, stats[i]));
 				else
-					sb.append(String.format("Col: %3d, No Compress, Type: %s\n", //
-						i, in.getColumn(i).getClass().getSimpleName()));
+				//  if(stats[i].shouldCompress)
+					sb.append(String.format("Col: %3d, %s\n", i, stats[i]));
+				// else
+					// sb.append(String.format("Col: %3d, No Compress, Type: %s\n", //
+						// i, in.getColumn(i).getClass().getSimpleName()));
 			}
 			LOG.debug(sb);
 		}