你是不是把"chooserecommend"这个当成字段名传过去了？

你是说自动解析成带双引号的？这个不会吧？
还是说你说自己写的SQL必须带双引号的？

sc.textFile(args(0))   读取这个变量地址指定的文件
.flatMap(.split(" "))     把文件中每一行按空格分割并转成多行
.map((, 1))            把上面转成多行中的每一项转换成一组一组的数据，每组数据为自身加1的组合
.reduceByKey(+)       把每组数据的value值进行累加，也就是把每组数据的所有1进行累加，求出每组key的总数
.sortBy(_.2, false)    按上一步每组的累加值进行排序

在scala中如果函数中只有一个变量那可以不写，或者使用匿名变量
代码里的(, 1) 这个就是逗号前面有个匿名变量
_.2 这个 就是代表元组的第2个值 可以写成这样的形式f => {f._2} 那这个f和_就是一个意思了

没明白你要设置成hdfs上的路径吗？还是配置什么东西。
HDFS上的数据路径就以hdfs开头啊

这里能设置JDBC连接吗？

亲，后两个图片上传失败了

@好好学习 这个应该是好使了

默认region split策略。根据公式min(r^2*flushSize，maxFileSize)确定split的maxFileSize，其中r为在线region个数，maxFileSize由hbase.hregion.max.filesize指定

你是指这个意思吗？
所谓的边缘节点即集群内部用来向集群外暴露服务能力的节点，集群外部的服务通过该节点来调用集群内部的服务，边缘节点是集群内外交流的一个Endpoint。

首先列表的每一项是字典，所以先循环列表的每一项取出字典，然后再取出字典中3的那个key

调出info信息看一下吧

把相关jar包放在spark的jars目录里就行了

@程序媛 5.7