我试图查询存储在Hive中的表 . 以下是我的QL . 我想将结果存回现有的hive表中新的分区 . 我的最后一行代码是创建一个新表 . 在将输出作为文件写入时，它正在存储镶木地板文件，但我无法通过配置单元进行读取 . 你能帮忙吗？
我的目标表：
CREATE EXTERNAL TABLE dq_reslt_detl_master（
DQ_CHECK_ID字符串，PK_1字符串，
PK_2 int，
D_RUNTIME string）PARTITIONED BY（
eap_as_of_dt string）存储为parquet文件位置'/data/test/dq_reslt_detl_master'
来自pyspark的pyspark导入sql导入来自pyspark.sql.types的SQLContext，Row，HiveContext导入*
sqlContext=HiveContext(sc)
dfsql=sqlContext.sql("""select * from l1_amlmkt_mdwe.mdw_atlas_te """)
dfsql.registerTempTable("tmp_mdw_atlas_te")
dfsql_=dfsql_Cache.count()
l1=['trd_ex_event_nb']
i_detl_all=[]
for i in l1:
i_summ_1_sql="select count(*) from amlmkt.k where {0} is null or {0} ='' ".format(i)
i_detl_1_sql="select x,y,from_unixtime(unix_timestamp())as exe_time from l1_amlmkt_mdwe.mdw_atlas_te where {0} is null or {0} ='' ".format(i)
i_detl_2=sqlContext.sql(i_detl_1_sql)
i_summ_2=sqlContext.sql(i_summ_1_sql)
i_detl_2.write.saveAsTable("dq_result")