我正在IntelliJ中创建和测试一个机器学习模型,该模型将对来自流的传入数据进行分类。我正在Scala (2.11.8)和使用Flink框架(1.8.3)中工作。我正在尝试读取一个csv文件,该文件包含具有长、双和布尔数据类型的列中的培训数据,这些数据类型如下:
val env = ExecutionEnvironment.getExecutionEnvironment
val trainingDS = env.readCsvFile(./training.csv)(DataSet[(Long, Double, Boolean)])我得到的错误是:“未指定的值参数证据$2”。此参数对应于TypeInformation参数。
我需要做什么更改来指定这个参数?我的导入包括:导入org.apache.flink.api.scala._导入org.apache.flink.streaming.api.scala._
附加信息:readCsvFileT : ClassTag : TypeInformation:DataSetT
发布于 2020-08-14 17:25:33
我相信那应该是
val trainingDS = env.readCsvFile[(Long, Double, Boolean)]("./training.csv")https://stackoverflow.com/questions/63377521
复制相似问题