3 个回答
可以使用如下的sql查询某张表的快照,示例如下:
这里的查询结果会展示所有的快照列表信息,示例如下:
select * from test1.default.users.snapshots
这里的查询结果会展示所有的快照列表信息,示例如下:
发布于:8个月前 (01-25) IP属地:四川省
那我如果要查询某一个具体快照的数据怎么办呢?
发布于:8个月前 (01-25) IP属地:未知
那我如果要查询某一个具体快照的数据怎么办呢?
这时候就不能使用sql进行查询了,得使用spark3.0的版本,执行如下的代码查询,示例如下:
主要的核心有:
示例效果图如下:
spark.read.option("snapshot-id",4051482671873089641L)
.format("iceberg")
.load("hdfs://node1:9000/spark_iceberg//default/users")
.show()
主要的核心有:
1、指定某个快照的id
2、load对应的hdfs上的表路径
示例效果图如下:
发布于:8个月前 (01-25) IP属地:四川省
我来回答
您需要 登录 后回答此问题!