readcsvfile错误:如何为类型的证据参数指定隐式值

fiei3ece  于 2021-06-21  发布在  Flink
关注(0)|答案(1)|浏览(381)

我在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]

1cosmwyk

1cosmwyk1#

我认为应该是这样

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

相关问题