Iceberg如何查询某张表的所有快照信息?

提问者:帅平 问题分类:大数据
Iceberg如何查询某张表的所有快照信息?
3 个回答
浮°
浮°
可以使用如下的sql查询某张表的快照,示例如下:
select * from test1.default.users.snapshots

这里的查询结果会展示所有的快照列表信息,示例如下:
发布于:6个月前 (01-25) IP属地:四川省
帅平
帅平提问者
那我如果要查询某一个具体快照的数据怎么办呢?
发布于:6个月前 (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上的表路径

示例效果图如下:
发布于:6个月前 (01-25) IP属地:四川省
我来回答