apache-spark - 使用Java在Spark中进行映射

Question

我的文件名为 myFile ，格式如下:

1,A,2,B
1,A,3,C
2,B,4,D

我想将每行的第二个索引值映射到该行本身:

A -> 1,A,2,B
A -> 1,A,3,C
B -> 2,B,4,D

如何使用Spark Java实现此目标？

Answer 1

这就是我实现的方式

JavaPairRDD<String, String> pairs = myFile.mapToPair(s->new Tuple2<>(s.split(",")[1], s));