微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

02_spark_sql

  1. json文件

    M:192.168.249.70

    Worker:71/72   json文件要分发到worker节点

image.png

image.png

{"name":"lili","salary":3000}

{"name":"andy","salary":4000}

{"name":"tom","salary":5000}

{"name":"pipi","salary":6000}

{"name":"alice","salary":7000}

{"name":"to","salary":7000}

2.跑数据

./bin/spark-shell   --master spark://192.168.249.70:7077

 var  df =  spark.read.json("examples/employ.json")

 df.show()

image.png

3.

4.

5.

6.

7.


版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 [email protected] 举报,一经查实,本站将立刻删除。

相关推荐