Spark 关于判断空RDD的速率

如题,我有如下操作,var temp = sqlContext.sql("select * from Queue where id>8") temp可能返回的是空RDD(存在分区),此时我使用temp.rdd.take(1).length判断是否为空,为什么空RDD非空RDD消耗的时间更长呢?

阅读 5.5k
撰写回答
你尚未登录,登录后可以
  • 和开发者交流问题的细节
  • 关注并接收问题和回答的更新提醒
  • 参与内容的编辑和改进,让解决方法与时俱进