基础

spark.sql("create database myDB")

spark.sql("create table mytab( 列名 类型 , ...... )")

spark.sql("drop database myDB")

spark.sql("drop table mytab")

spark.sql("show databases")

spark.sql("show tables")

spark.sql("use myDB")

查询

rank over()

rank over( partition by 字段名 order by 列名 )

分区
partition by 字段名

排序
oreder by 字段名 默认升序 / 降序 desc

例子：