scala - readCsvFile 错误：如何为类型的证据参数指定隐式值

Question

我在 IntelliJ 中工作以创建和测试一个机器学习模型，该模型将对来自流的传入数据进行分类。我正在使用 Scala (2.11.8) 并使用 Flink 框架 (1.8.3)。我正在尝试读取一个 csv 文件，该文件包含我的训练数据，其中包含 long、double 和 boolean 数据类型的列，其中包含以下几行：

val env = ExecutionEnvironment.getExecutionEnvironment
val trainingDS = env.readCsvFile(./training.csv)(DataSet[(Long, Double, Boolean)])

我得到的错误是：“未指定的值参数evidence$2。” 此参数对应于 TypeInformation 参数。

我需要进行哪些更改才能指定此参数？我的导入包括： import org.apache.flink.api.scala._ import org.apache.flink.streaming.api.scala._

附加信息： readCsvFile [T : ClassTag : TypeInformation](filePath: String): DataSet[T]

Answer 1

我相信应该是

val trainingDS = env.readCsvFile[(Long, Double, Boolean)]("./training.csv")