赞
踩
在右边命令行,逐个输入以下几个命令就ok了!
spark-shell
val textFile = spark.read.textFile("/data/workspace/myshixun/phone.txt")
val zt_ws_records = textFile.filter(line =>(line.contains("张涛") && line.contains("王世昌")) || (line.contains("王世昌") && line.contains("张涛")))
zt_ws_records.write.text("/root/re")
:quit
- #!/bin/bash
-
- cp -r Spark/SparkRDD/target/project.jar /root
- cd /opt/spark/dist/bin
- #********** Begin **********#
- ./spark-submit \
- --class Student \
- --master local \
- /root/project.jar
- #********** End **********#
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。