спарк-редис конектор для скала 2.11 - PullRequest
Новая
       21

спарк-редис конектор для скала 2.11

0 голосов
/ 31 мая 2018

Я ищу решение, в котором я могу сохранить потоковое СДР kafka в Redis с помощью zscore и в режиме добавления.Есть ли у нас какой-либо Коннектор для этого - пробный разъем RedisLabs, но он совместим только с Scala 2.10.Есть еще один github от Anchormen https://github.com/Anchormen/spark-redis-connector, но ему опять не хватает документации, а также jar недоступен на maven.

 collection.foreachRDD(rdd =>
      {
        if (!rdd.partitions.isEmpty) {
        // save rdd to redis as list with zscore 
        }
      })

Итак, любые предложения, пожалуйста.Спасибо,

...