diff --git a/src/main/java/org/apache/sysds/runtime/matrix/data/LibMatrixFourier.java b/src/main/java/org/apache/sysds/runtime/matrix/data/LibMatrixFourier.java index 9f7fb02723a..dd84da5b7d8 100644 --- a/src/main/java/org/apache/sysds/runtime/matrix/data/LibMatrixFourier.java +++ b/src/main/java/org/apache/sysds/runtime/matrix/data/LibMatrixFourier.java @@ -21,11 +21,6 @@ import org.apache.commons.math3.util.FastMath; -import org.apache.sysds.runtime.util.CommonThreadPool; - -import java.util.concurrent.ExecutorService; -import java.util.concurrent.TimeUnit; - public class LibMatrixFourier { /** @@ -180,7 +175,6 @@ private static void ifft_one_dim(double[] re, double[] im, double[] re_inter, do } // apply fft - //fft_one_dim_recursive(re, im, re_inter, im_inter, start, step, num, subArraySize); fft_one_dim(re, im, re_inter, im_inter, start, stop, num, minStep); // conjugate and scale result @@ -225,17 +219,4 @@ public static MatrixBlock[] ifft(MatrixBlock re){ return ifft(re, new MatrixBlock(re.getNumRows(),re.getNumColumns(), new double[re.getNumRows()*re.getNumColumns()])); } - public static void awaitParallelExecution(ExecutorService pool) { - - try { - int timeout = 100; - if(!pool.awaitTermination(timeout, TimeUnit.SECONDS)) { - pool.shutdownNow(); - } - } - catch(InterruptedException e) { - e.printStackTrace(); - } - } - }