
# Scala样例代码
#### 功能简介
统计日志文件中本周末网购停留总时间超过2个小时的女性网民信息。
#### 代码样例
下面代码片段仅为演示，具体代码参见com.huawei.bigdata.spark.examples.FemaleInfoCollection。
样例代码获取方式请参考[获取MRS应用开发样例工程](https://support.huaweicloud.com/devg-mrs/mrs_06_0002.html)。
代码样例：
```
//配置Spark应用名称
val conf = new SparkConf().setAppName("CollectFemaleInfo")
//提交Spark作业
val sc = new SparkContext(conf)
//读取数据。传入参数args(0)指定数据路径
val text = sc.textFile(args(0))
//筛选女性网民上网时间数据信息
val data = text.filter(_.contains("female"))
//汇总每个女性上网时间
val femaleData:RDD[(String,Int)] = data.map{line =>
    val t= line.split(',')
    (t(0),t(2).toInt)
}.reduceByKey(_ + _)
//筛选出时间大于两个小时的女性网民信息，并输出
val result = femaleData.filter(line => line._2 > 120)
result.foreach(println)
```
