这个加载操作给我一个元组列表
不，它会给你一个 RDD[String] .
你可以把字符串转换成你想要的任何东西。
对于您的用例，您可以将每一行转换为（（a，b，c），（d，e，f，g，h，i））

f1 = sc.textFile("s3://testfolder1/file1").map { line =>
val a::b::c::d::e::d::f::g::h::i::other = line.split(YOUR_DELIMITER).toList
((a,b,c),(d,e,f,g,h,i))
}

f2 = sc.textFile("s3://testfolder1/file1").map { line =>
val a::b::c::d::e::d::f::g::h::i::other = line.split(YOUR_DELIMITER).toList
((a,b,c),(d,e,f,g,h,i))
}

然后， f1.join(f2) 应该就行了。