有没有spark sql调用查询iceberg的代码案例?

提问者:帅平 问题分类:大数据
有没有spark sql调用查询iceberg的代码案例?
1 个回答
ε小仙女の日常з
ε小仙女の日常з
spark sql调用查询iceberg的案例如下:
SparkSession spark = SparkSession
                .builder()
                .master("local")
                .appName("Iceberg spark example")
                .config("spark.sql.extensions", "org.apache.iceberg.spark.extensions.IcebergSparkSessionExtensions")
                .config("spark.sql.catalog.local", "org.apache.iceberg.spark.SparkCatalog")
                .config("spark.sql.catalog.local.type", "hadoop") //指定catalog 类型
                .config("spark.sql.catalog.local.warehouse", "iceberg_warehouse")
                .getOrCreate();
 spark.sql("CALL local.system.rollback_to_snapshot('iceberg_db.table2', 3285133177610707025) ");
发布于:3个月前 (01-21) IP属地:四川省
我来回答