>>> schemardd can exec SQL stamens?
> 在 2014年9月2日，20:42，Silvio Fiorito <[email protected]> 写道： > > 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] > --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
