小编dav*_*028的帖子

Spark HiveContext不会从Hive Table中检索新插入的记录

我正在使用Spark 1.4.HiveContext用于连接Hive.我做了以下

val hx = new HiveContext(sc)
import hx.implicits._
hx.sql("select * from tab").show
Run Code Online (Sandbox Code Playgroud)

//很好,结果显示为预期

然后,我从直线控制台插入一些记录到选项卡

hx.refreshTable("tab")
hx.sql("select * from tab").show
Run Code Online (Sandbox Code Playgroud)

//仍然是旧记录,没有新插入的记录

我的问题是:为什么HiveContext没有检索新插入的记录?

apache-spark-sql

7
推荐指数
1
解决办法
2161
查看次数

标签 统计

apache-spark-sql ×1