直接上code

%spark.pyspark
schema = None
sep = ','
header = True
tf = spark.read.csv(path = '/models/Data/hive-campaignid.csv', schema = schema ,sep = sep, header = header)

tf.createOrReplaceTempView("mytempTable") 
sqlContext.sql("insert overwrite table temp.ld_campaignid as select * from mytempTable")

2019-03-26 于南京市栖霞区紫东