I'm learning readCsvFile
(I discover if the file ends on "/n", you will return a null exception)

*if I try to read only 1 column *

val text4 = env.readCsvFile[String]("file:data.csv" ,includedFields = Array(1))

The error is: he type String has to be a tuple or pojo type. [null]




*If  I put > 1 column; (*1º and 2º in this case*)*

val text4 = env.readCsvFile [(String,String)]("data.csv"
  ,fieldDelimiter = ","
  ,includedFields = Array(0,1))

Read all columns from, CSV (3 in my example)
a,b,c
aa,bb,c

Reply via email to