• 15.pipe(command, [envVars])调用脚本
• 14.sortBy(func,[ascending], [numTasks])
• 13.增加缩减分区
• 12.distinct([numTasks]))去重复
• 11.takeSample按个数取样
• 10.sample(withReplacement, fraction, seed)采样
• 09.filter(func)
• 08.GroupBy之WordCount
• 07.groupBy(func)
• 06.glom()分区转换数组
• 05.flatMap(func)压平
• 04.map()和mapPartitions()的区别
• 03.mapPartitionsWithIndex(func)
• 02.mapPartitions(func)
• 01.map(func)