Spark Streaming-transform以及广告计费日志实时黑名单过滤案例实战

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

>>阅读原文<<