Spark源码值提交任务

 /**
   * Return the number of elements in the RDD.
   */
  def count(): Long = sc.runJob(this, Utils.getIteratorSize _).sum

View Code

【推广】免费学中医，健康全家人

原文地址：https://www.cnblogs.com/chengbao/p/10546757.html