Spark-Streaming之transform操做，實時黑名單過濾案例

Transform操做，應用在DStream上時，能夠用於執行任意的RDD到RDD的轉換操做。它能夠用於實現，DStream API中所沒有提供的操做。好比說，DStream API中，並無提供將一個DStream中的每一個batch，與一個特定的RDD進行join的操做。可是咱們本身就能夠使用transform操做來實現該功能。 DStream.join()，只能join其餘DStream。在D

>>阅读原文<<