问题标签 [spark-redis]

使用 Spark-redis（在 Java 中）https://github.com/RedisLabs/spark-redis，我正在尝试检索几个持久列表、列表名称以及值。但这似乎是不可能的。我尝试使用 fromRedisList提供一个键模式作为输入。我确实检索了所有值，不幸的是只有匹配列表的值，存储在RDD<String>我无法获取包含该值的匹配列表的名称。

有什么方法可以检索列表名称吗？（作为RedisKV的比较返回 RDD<Tuple2<String, String>>，包含键和值，所以当给一个键模式作为输入时，我可以获得真正的匹配键）

谢谢

我有一个对象列表。我使用 foreach 通过 objectId 从 redis 读取。我使用 spark-redis 库连接 Redis。

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

我正在尝试实现从 Redis Stream 读取的 Apache Spark Streaming 作业。我收到以下错误：

Java 代码如下：

转换器代码如下：

我尝试寻找 Apache Spark Streaming 的示例，但没有成功，它是一个与 Kafka 一起工作的现有应用程序。

任何输入都受到高度赞赏。

POM.xml