Spark-Streaming之transform操做,实时黑名单过滤案例

Transform操做,应用在DStream上时,能够用于执行任意的RDD到RDD的转换操做。它能够用于实现,DStream API中所没有提供的操做。好比说,DStream API中,并无提供将一个DStream中的每一个batch,与一个特定的RDD进行join的操做。可是咱们本身就能够使用transform操做来实现该功能。 DStream.join(),只能join其余DStream。在D
相关文章
相关标签/搜索