Baunsgaard commented on a change in pull request #1207:
URL: https://github.com/apache/systemds/pull/1207#discussion_r613136603



##########
File path: src/test/scripts/functions/io/csv/csv_verify2.R
##########
@@ -26,7 +26,8 @@ options(digits=22)
 
 library(Matrix);
 
-A = read.csv(args[1]);
+A = read.csv(args[1], header=TRUE, sep=",");

Review comment:
       should not be modified

##########
File path: src/test/scripts/functions/io/csv/ReadCSVTest_2.dml
##########
@@ -20,8 +20,7 @@
 #-------------------------------------------------------------
 
 # DML script that tests read csv
-
-A = read($1, format="csv", header=TRUE);
+A = read($1, format="csv", header=TRUE, sep=",");

Review comment:
       should not be modified

##########
File path: src/main/java/org/apache/sysds/runtime/io/ReaderTextCSVParallel.java
##########
@@ -121,8 +122,9 @@ private void readCSVMatrixFromHDFS(InputSplit[] splits, 
Path path, MatrixBlock d
 
                FileInputFormat.addInputPath(_job, path);
                TextInputFormat informat = new TextInputFormat();
-               informat.configure(_job);
 
+               informat.configure(_job);
+    

Review comment:
       should not be modified

##########
File path: src/main/java/org/apache/sysds/runtime/io/ReaderTextCellParallel.java
##########
@@ -256,7 +256,7 @@ public Void call() throws Exception {
                        LongWritable key = new LongWritable();
                        Text value = new Text();
                        FastStringTokenizer st = new FastStringTokenizer(' ');
-                       
+

Review comment:
       should not be modified

##########
File path: src/main/java/org/apache/sysds/runtime/io/ReaderTextCSV.java
##########
@@ -58,13 +59,13 @@ public MatrixBlock readMatrixFromHDFS(String fname, long 
rlen, long clen, int bl
                        ret = createOutputMatrixBlock(rlen, clen, (int)rlen, 
estnnz, true, false);
                
                //prepare file access
-               JobConf job = new 
JobConf(ConfigurationManager.getCachedJobConf());     
+               JobConf job = new 
JobConf(ConfigurationManager.getCachedJobConf());
                Path path = new Path( fname );
                FileSystem fs = IOUtilFunctions.getFileSystem(path, job);
                
                //check existence and non-empty file
-               checkValidInputFile(fs, path); 
-       
+               checkValidInputFile(fs, path);
+

Review comment:
       should not be modified




-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

For queries about this service, please contact Infrastructure at:
[email protected]


Reply via email to