spark自己实现并行化logistic回归？

怎么使用spark实现并行化的logistic回归，并行化体现在哪里？如果用mapreduce的话需要自己写map和reduce，但是spark怎么弄呢？spark的map和reduce和一般的map、reduce有什么关系吗？怎么理解？