Hi, I'm trying to map a Dataset<Row> that read from csv files into a Dataset<Integer>. But it gives some errors. Can anyone please help me to figure it out?
Dataset<Row> t_en_data = session.read().option("header","true") .option("inferSchema","true") .csv("J:\\csv_path\\T_EN"); Dataset<Integer> mappedDataset = t_en_data .map((MapFunction<Row, Integer>) row ->row.<Integer>getAs("Duration"), Encoders.INT()); mappedDataset.show(false); error - https://gist.github.com/anonymous/614a1746162dd12bb0b810add85deda2 Thanks -- Himasha De Silva