Я пишу скрипт Scala для обработки файла csv в Apache Flink, используя API потока данных. Мне нужно исправить формат для некоторых столбцов, а затем привести их к нужным типам. Мой текущий код таков: package org.myorg.tareac import...