赞
踩
训练要点
(1) 读取数据创建RDD。
(2) 通过filter操作过滤数据,filter的函数判断数据是否包含“男”字符,可用“contains”方法。
(3) 用count对步骤(2)的结果进行统计,得到行数
import org.apache.spark.{
SparkConf, SparkContext}
object SparkPi {
def main(args: Array[String]): Unit = {
val conf = new SparkConf(
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。