0

我有一个对象列表。我使用 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)
  }
})

如何检查表是否存在以供阅读。

4

0 回答 0