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]
