A. 사실

B. 거짓

A. 절약

B. taildir

C. Log4j

D. JMS

A. 사실

B. 거짓

A. 실행

B. 열다

C. 방출

D. 넥스트튜플

A. sc.textFile( " /data/file/path " .map(_.split( " , " ).map(p => FemaleInfo(p(0), p(1), p(2))) . trim.tolnt)).toDF.registerTempTable("FemaleInfoTable") sqlContext.sql("성별 = ' 여성 '" ).filter( " stayTime >= 120 " ).collect ().foreach(println)

B. sc.textFile( " /data/file/path " .map(_.split( " , " ).map(p => FemaleInfo(p(0), p(1), p(2))) . trim.tolnt)).toDF.registerTempTable("FemaleInfoTable") sqlContext.sql("이름, sum(stayTime)을 FemaleInfoTable에서 stayTime으로 선택, 여기서 성별 = ' 여성 ' 이름별 그룹 " ).filter( " stayTime >= 120 " ).collect().foreach(println)

C. val text = sc.textFile("/data/file/path") val data = text.filter(_.contains("female")) val femaleData:RDD[(String,Int)] = 데이터. map{Iine => val t = line.split( ' , ' ) (t(0),t(2).tolnt) }. 값 결과 = 여성데이터.필터(라인 => 라인._2> 120) 결과.collect().map(x => x._1 + ', ' + x._2).foreach(println)

D. val text = sc.textFile("/data/file/path") val data = text.filter(_.contains("female")) val femaleData:RDD[(String,Int)] = 데이터. map{Iine => val t = line.split( ' , ' ) (t(0),t(2).tolnt) }.reduceByKey(_ + _) val result = femaleData.filter(line => line._2 > 120) result.collect().map(x => x._1 + ' , ' + x._2).foreach(println)