Spark算子执行流程详解之一

1.take 获取前num条记录。java def take(num: Int): Array[T] = withScope {   if (num == 0) {     new Array[T](0)   } else {     val buf = newArrayBuffer[T]     val totalParts = this.partitions.length     var pa

>>阅读原文<<