首页 > 在SparkSQL中,registerTempTable如何insert新的内容?

在SparkSQL中,registerTempTable如何insert新的内容?

描述如下: PersonRdd是一群Person类的Rdd,然后进行PersonRdd.registerTempTable("Person")操作把其注册到Person表中, 但是我现在又要增加Person表的内容(不是指增加字段的意思,仅是insert into的概念),该怎么办?我的做法是把PersonRdd做一个cache,然后对于新增内容搞成一个TempRdd,然后进行Union,新生成的RDD再进行registerTempTable("Person"),不知道还有什么比较好的方法可以直接添加进Person表中,初学望能赐教,在此谢过!

【热门文章】
【热门文章】