Spark2.0功能测试和日志查看

一、spark2.0功能测试 1.Spark-shell 在spark的sbin使用spark-shell命令开启,使用如下例子测试: scala>val file=sc.textFile("hdfs://namenode:9000/user/hadoop/input/core-site.xml") scala>val count=file.flatMap(line=>line.split(" "
相关文章
相关标签/搜索