flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Alberto Ramón <a.ramonporto...@gmail.com>
Subject readCsvFile
Date Thu, 06 Oct 2016 18:59:51 GMT
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)

Mime
View raw message