如何将redis转换为spark数据集或dataframe？

import org.apache.spark.sql.{Row, SparkSession}
import org.apache.spark.sql.types.{StringType, StructField, StructType}

val spark = SparkSession.builder()
  .appName("Redis to Spark")
  .master("local")
  .getOrCreate()

// 创建连接到Redis的连接器
val redisConfig = Map("host" -> "localhost", "port" -> "6379")
val redisRDD = spark.sparkContext.fromRedisKV(redisConfig)

// 将Redis的RDD转换为Row对象的RDD
val rowRDD = redisRDD.map(kv => Row(kv._1, kv._2))

// 定义DataFrame的模式
val schema = StructType(Seq(
  StructField("key", StringType, nullable = false),
  StructField("value", StringType, nullable = false)
))

// 将Row对象的RDD转换为DataFrame
val df = spark.createDataFrame(rowRDD, schema)

// 使用DataFrame进行查询和处理
df.show()