diff options
| author | Reynold Xin <rxin@apache.org> | 2013-11-06 13:27:47 -0800 |
|---|---|---|
| committer | Reynold Xin <rxin@apache.org> | 2013-11-06 13:27:47 -0800 |
| commit | aadeda5e7697a433c82879033e758fbc403680dc (patch) | |
| tree | 3208ff06042e86f95de185524b6c94241af309ae /spark-executor | |
| parent | 951024feeadcf73b50c3c80ec9e75c7e2214a7a4 (diff) | |
| parent | a0c4565183b1dcfa816f280ddf9c60c4c117df06 (diff) | |
| download | spark-aadeda5e7697a433c82879033e758fbc403680dc.tar.gz spark-aadeda5e7697a433c82879033e758fbc403680dc.tar.bz2 spark-aadeda5e7697a433c82879033e758fbc403680dc.zip | |
Merge pull request #144 from liancheng/runjob-clean
Removed unused return value in SparkContext.runJob
Return type of this `runJob` version is `Unit`:
def runJob[T, U: ClassManifest](
rdd: RDD[T],
func: (TaskContext, Iterator[T]) => U,
partitions: Seq[Int],
allowLocal: Boolean,
resultHandler: (Int, U) => Unit) {
...
}
It's obviously unnecessary to "return" `result`.
Diffstat (limited to 'spark-executor')
0 files changed, 0 insertions, 0 deletions