spark sql 读取hudi 表数据

您可以使用Spark SQL读取Hudi表数据。首先，您需要将Hudi作为数据源注册到SparkSession中。以下是一个示例代码：

import org.apache.spark.sql.SparkSession

val spark = SparkSession.builder()
  .appName("HudiExample")
  .master("local")
  .getOrCreate()

// 将Hudi库添加到SparkSession
spark.sql("ADD JAR /path/to/hudi-spark-bundle.jar")

// 注册Hudi数据源
spark.sql("CREATE TEMPORARY VIEW hudi_table USING org.apache.hudi " +
  "OPTIONS (path 'hdfs://path/to/hudi_table', " +
  "tableName 'hudi_table', " +
  "recordKey 'id', " +
  "preCombineKey 'timestamp')")

// 查询Hudi表数据
val query = "SELECT * FROM hudi_table"
val hudiData = spark.sql(query)

hudiData.show()

在上面的代码中，您需要将`/path/to/hudi-spark-bundle.jar`替换为您的Hudi Spark Bundle JAR文件的路径。同时，您需要将`hdfs://path/to/hudi_table`替换为您实际的Hudi表路径。

注册Hudi数据源后，您可以使用Spark SQL查询Hudi表数据。在示例中，我们执行了一个简单的SELECT查询，并使用`show()`方法显示结果。

请注意，此示例假定您已经设置好了Spark和Hudi的环境。如果您还没有安装和配置Spark和Hudi，请按照相关文档进行操作。