diff --git a/src/main/java/org/apache/sysds/runtime/transform/encode/MultiColumnEncoder.java b/src/main/java/org/apache/sysds/runtime/transform/encode/MultiColumnEncoder.java index fc63efffee7..abe39a34a0d 100644 --- a/src/main/java/org/apache/sysds/runtime/transform/encode/MultiColumnEncoder.java +++ b/src/main/java/org/apache/sysds/runtime/transform/encode/MultiColumnEncoder.java @@ -710,28 +710,28 @@ public FrameBlock getMetaData(FrameBlock meta, int k) { return _meta; if(meta == null) meta = new FrameBlock(_columnEncoders.size(), ValueType.STRING); - this.allocateMetaData(meta); - if(k > 1) { - ExecutorService pool = CommonThreadPool.get(k); - try { - ArrayList> tasks = new ArrayList<>(); - for(ColumnEncoder columnEncoder : _columnEncoders) - tasks.add(new ColumnMetaDataTask<>(columnEncoder, meta)); - List> taskret = pool.invokeAll(tasks); - for(Future task : taskret) - task.get(); - } - catch(Exception ex) { - throw new DMLRuntimeException(ex); - } - finally { - pool.shutdown(); - } - } - else { - for(ColumnEncoder columnEncoder : _columnEncoders) - columnEncoder.getMetaData(meta); - } + // this.allocateMetaData(meta); + // if(k > 1) { + // ExecutorService pool = CommonThreadPool.get(k); + // try { + // ArrayList> tasks = new ArrayList<>(); + // for(ColumnEncoder columnEncoder : _columnEncoders) + // tasks.add(new ColumnMetaDataTask<>(columnEncoder, meta)); + // List> taskret = pool.invokeAll(tasks); + // for(Future task : taskret) + // task.get(); + // } + // catch(Exception ex) { + // throw new DMLRuntimeException(ex); + // } + // finally { + // pool.shutdown(); + // } + // } + // else { + // for(ColumnEncoder columnEncoder : _columnEncoders) + // columnEncoder.getMetaData(meta); + // } // _columnEncoders.stream().parallel().forEach(columnEncoder -> // columnEncoder.getMetaData(meta));