直接上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 于南京市栖霞区紫东
