java spark streaming rdd 判斷 是否爲null

rdd.count() 和rdd.isEmpty()

最粗暴的辦法，適用與一切

rdd.partitions().isEmpty()

這種比較適合Dstream 進來後沒有通過 相似 reduce 操做的 。

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

這種就能夠用來做爲 通過 reduce 操做的 了