You can use saveAsTable or do an INSERT SparkSQL statement as well in case you need other Hive query features, like partitioning.
On 9/2/14, 6:54 AM, "centerqi hu" <[email protected]> wrote: >I got it > >import org.apache.spark.{SparkConf, SparkContext} >import org.apache.spark.sql._ >val hiveContext = new org.apache.spark.sql.hive.HiveContext(sc) >import hiveContext._ >val usermeta = hql(" SELECT userid,idlist from meta WHERE >day='2014-08-01' limit 1000") >case class SomeClass(name:String,idlist:String) >val scmm = usermeta.map(t=>{SomeClass(t(0).toString,t(1).toString >+"iddddddddd")}) >val good = createSchemaRDD(scmm) >good.saveAsTable("meta_test") > >2014-09-02 17:50 GMT+08:00 centerqi hu <[email protected]>: >> I want to save schemardd to hive >> >> val usermeta = hql(" SELECT userid,idlist from usermeta WHERE >> day='2014-08-01' limit 1000") >> case class SomeClass(name:String,idlist:String) >> val schemardd = >>usermeta.map(t=>{SomeClass(t(0).toString,t(1).toString)}) >> >> How to save schemardd to hive? >> >> Thanks >> >> -- >> [email protected]|齐忠 > > > >-- >[email protected]|齐忠 > >--------------------------------------------------------------------- >To unsubscribe, e-mail: [email protected] >For additional commands, e-mail: [email protected] > --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
