Fix Formatting

Author: janniklinde

src/main/java/org/apache/sysds/runtime/ooc/cache/OOCCacheManager.java

@@ -31,6 +31,7 @@
 import java.io.IOException;
 import java.nio.file.Files;
 import java.nio.file.Path;
+import java.util.ArrayList;
 import java.util.List;
 import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.atomic.AtomicBoolean;
@@ -187,7 +188,7 @@ public static CompletableFuture<OOCStream.QueueCallback<IndexedMatrixValue>> req
 	public static CompletableFuture<List<OOCStream.QueueCallback<IndexedMatrixValue>>> requestManyBlocks(List<BlockKey> keys) {
 		return getCache().request(keys).thenApply(
 			l -> {
-				List<OOCStream.QueueCallback<IndexedMatrixValue>> out = new java.util.ArrayList<>(l.size());
+				List<OOCStream.QueueCallback<IndexedMatrixValue>> out = new ArrayList<>(l.size());
 				for (int i = 0; i < l.size(); i++)
 					out.add(toCallback(l.get(i), keys.get(i), null));
 				return out;
@@ -198,7 +199,7 @@ public static List<OOCStream.QueueCallback<IndexedMatrixValue>> tryRequestManyBl
 		List<BlockEntry> entries = getCache().tryRequest(keys);
 		if(entries == null)
 			return null;
-		List<OOCStream.QueueCallback<IndexedMatrixValue>> out = new java.util.ArrayList<>(entries.size());
+		List<OOCStream.QueueCallback<IndexedMatrixValue>> out = new ArrayList<>(entries.size());
 		for (int i = 0; i < entries.size(); i++)
 			out.add(toCallback(entries.get(i), keys.get(i), null));
 		return out;
@@ -208,7 +209,7 @@ public static CompletableFuture<List<OOCStream.QueueCallback<IndexedMatrixValue>
 		return getCache().requestAnyOf(keys, n, sel)
 			.thenApply(
 				l -> {
-					List<OOCStream.QueueCallback<IndexedMatrixValue>> out = new java.util.ArrayList<>(l.size());
+					List<OOCStream.QueueCallback<IndexedMatrixValue>> out = new ArrayList<>(l.size());
 					for (int i = 0; i < l.size(); i++) {
 						BlockKey key = sel.size() == l.size() ? sel.get(i) : keys.get(i);
 						out.add(toCallback(l.get(i), key, null));
@@ -218,7 +219,7 @@ public static CompletableFuture<List<OOCStream.QueueCallback<IndexedMatrixValue>
 	}
 
 	private static OOCStream.QueueCallback<IndexedMatrixValue> toCallback(BlockEntry entry, BlockKey key, DMLRuntimeException failure) {
-		if (entry.getData() instanceof java.util.List<?>) {
+		if (entry.getData() instanceof List<?>) {
 			CachedGroupCallback<IndexedMatrixValue> group = new CachedGroupCallback<>(entry, failure);
 			if (key instanceof GroupedBlockKey gk) {
 				OOCStream.QueueCallback<IndexedMatrixValue> sub = group.getCallback(gk.getGroupIndex());

src/main/java/org/apache/sysds/runtime/ooc/stream/TaskContext.java

@@ -49,8 +49,6 @@ public static void defer(Runnable deferred) {
 		if(ctx._deferred == null)
 			ctx._deferred = new ArrayDeque<>();
 		ctx._deferred.add(deferred);
-		//if(ctx._deferred.size() == 4 || ctx._deferred.size() % 100 == 0)
-		//	System.out.println("[WARN] Defer size bigger than 3 (" + ctx._deferred.size() + ")");
 	}
 
 	public static boolean runDeferred() {