如何解决readCsvFile错误:如何为类型的证据参数指定隐式值
我正在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参数。
我需要进行哪些更改以指定此参数?我的进口包括: 导入org.apache.flink.api.scala._ 导入org.apache.flink.streaming.api.scala ._
其他信息: readCsvFile [T:ClassTag:TypeInformation](文件路径:字符串):DataSet [T]
解决方法
我认为应该
val trainingDS = env.readCsvFile[(Long,Double,Boolean)]("./training.csv")
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。