zoukankan      html  css  js  c++  java
  • spark学习——sql编程

      今天参照网上资料完成了相关的sql编程,其中遇到了一些问题,稍后给大家说。

      除了实验五的sql编程我还写了一些的实验六的内容,实验六完成的只剩下最高后一部分。

    1.Spark SQL 基本操作

    (1)    查询所有数据;

     

    (2)    查询所有数据,并去除重复的数据;

     

    (3)    查询所有数据,打印时去除 id 字段;

     

    (4)    筛选出 age>30 的记录;

     

    (5) 将数据按 age 分组;

          

    (6) 将数据按 name 升序排列;

     

    (7) 取出前 3 行数据;

          

    (8) 查询所有记录的 name 列,并为其取别名为 username;

     

    (9) 查询年龄 age 的平均值;

     

    (10) 查询年龄 age 的最小值。

          

    2.编程实现将 RDD 转换为 DataFrame

    请将数据复制保存到 Linux 系统中,命名为 employee.txt,实现从 RDD 转换得到DataFrame,并按“id:1,name:Ella,age:36”的格式打印出 DataFrame 的所有数据。请写出程序代码。

    源代码:

     

     

     

    3. 编程实现利用 DataFrame 读写 MySQL 的数据

         (1)在 MySQL 数据库中新建数据库 sparktest,再创建表 employee,包含如表 6-2 所示的

    两行数据。

     

     

        (2)配置 Spark 通过 JDBC 连接数据库 MySQL,编程实现利用 DataFrame 插入如表 6-3 所示的两行数据到 MySQL 中,最后打印出 age 的最大值和 age 的总和。

        源代码:

     

     

     


    遇到的问题,打包的时候出现了无法导包的相关问题。

    解决办法:将语句在spark-shell控制台一句一句的执行即可。

  • 相关阅读:
    Marketing learning-3
    xml文件的生成
    sharedPreferences
    Marketing learning-2
    图说不为人知的IT传奇故事-5-小型机之王
    Marketing learning-1
    图说不为人知的IT传奇故事-4-王安用一生来跟IBM抗衡
    图说不为人知的IT传奇故事-3-硅谷DNA创造者HP
    图说不为人知的IT传奇故事-2-IBM咬不动的胡桃
    图说不为人知的IT传奇故事-1-计算机新生
  • 原文地址:https://www.cnblogs.com/huan-ch/p/12307318.html
Copyright © 2011-2022 走看看