我在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)])
我得到的错误是:“未指定值参数证据$2”。这个参数对应于typeinformation参数。
我需要做什么更改才能指定此参数?我的导入包括:import org.apache.flink.api.scala.\uimport org.apache.flink.streaming.api.scala_
其他格式:readcsvfile[t:classtag:typeinformation](filepath:string):数据集[t]
1条答案
按热度按时间1cosmwyk1#
我认为应该是这样