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

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

阅读 4.5k
撰写回答
你尚未登录,登录后可以
  • 和开发者交流问题的细节
  • 关注并接收问题和回答的更新提醒
  • 参与内容的编辑和改进,让解决方法与时俱进