java spark streaming rdd 判断 是否为null

原创
2016/09/07 16:39
阅读数 1.7K

rdd.count() 和rdd.isEmpty()

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

rdd.partitions().isEmpty()

 这种比较适合Dstream 进来后没有经过 类似 reduce 操作的 。

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

 这种就可以用来作为 经过 reduce 操作的 了 
展开阅读全文
打赏
0
0 收藏
分享
加载中
更多评论
打赏
0 评论
0 收藏
0
分享
返回顶部
顶部