java spark streaming rdd 判断 是否为null

rdd.count() 和rdd.isEmpty()

最粗暴的办法，适用与一切

rdd.partitions().isEmpty()

这种比较适合Dstream 进来后没有通过 相似 reduce 操做的 。

rdd.rdd().dependencies().apply(0).rdd().partitions().length==0

这种就能够用来做为 通过 reduce 操做的 了