赞
踩
- import org.apache.flink.api.scala.{DataSet, ExecutionEnvironment}
- import org.apache.flink.api.scala._
-
- object DataSetWcApp {
- def main(a: Array[String]): Unit = {
- val env: ExecutionEnvironment = ExecutionEnvironment.getExecutionEnvironment
- val textDataSet: DataSet[String] =
- env.readTextFile("C:\\Users\\gxk\\Desktop\\hello.txt")
- textDataSet.flatMap(_.split(" ")).map((_, 1)).groupBy(0).sum(1).print()
-
- }
- }
解决隐式转换的包导入了就是报错
苦苦思索中..... 灵机一动
原来是因为本地安装的scala和程序中导入的scala jar包版本不一致导致的 !真的棒槌!!!
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。