Hi Jan,
First of all I'd rather recommend Table API for processing structured data.
However if you are convinced you want to use the DataStream API, the
CsvInputFormat supports the java.sql.Date type. You can try that or what
I would suggest is to parse the Date field as string and then parse it
Hi ,
i'm looking for an comfortable way to read a CSV file with the DataStream API
in Flink 1.11.
Without using the Table/SQL-API before.
This is my first approach:
val typeInfo =
TypeInformation.of(classOf[CovidEvent]).asInstanceOf[PojoTypeInfo[CovidEvent]]
val csvInputFormat = new
