HIVE表读数据并转成dict
1. 从HIVE表读数据并转成dictfrom pyspark import SparkContextfrom pyspark.sql import HiveContext,SparkSessionsc = SparkContext()sql_context = HiveContext(sc)sql_data = sqlContext.sql("SELECT key,value1,value2,value3 from db.table")sql_data_rdd = sql_