我有一个对象列表。我使用 foreach 通过 objectId 从 redis 读取。我使用 spark-redis 库连接 Redis。
listObject.foreach(obj=> {
if (obj.objectId != null) {
val tempAccumFromRedis = spark.read.format("org.apache.spark.sql.redis")
.option("table", obj.objectId)
.load().as[Object]
tempAccumFromRedis.printSchema()
accumFromRedisDs = accumFromRedisDs.union(tempAccumFromRedis)
}
})
如何检查表是否存在以供阅读。