spark streaming中transform過濾廣告黑名單

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