SparkStreaming整合Redis

需求：但願在Spark RDD算子中訪問Redis。redis 思路：經過Broadcast變量將Redis配置信息廣播到全部計算節點；經過lazy關鍵字實現Redis鏈接的延遲建立。apache 具體步驟：app 1.定義Redis客戶端包裝類分佈式 package xxxide   import redis.clients.jedis.{Jedis, JedisPool, JedisPoolC

>>阅读原文<<