前言咨询的划分情况
程序Jupyter #导入信息frompyspark.sqlimportsparksession,rowfrompysparkimportsqlcontextfrompyspark.SQL.functionsimportududd get_json_object,concat_ws,splitfrompyspark.SQL.typesimportstringtype,IntegerType, 结构类型映射# from offline _ verification _ func import * spark=spark session. builder.master (local [ 50 ] ) ) 在. getorcreate(#查询语句spark.SQL(''showpartitions表名' ' '.show ) ) Hive中显示#表分区: hive show partitions table 中show partitions table_name;