「HBase」から「スキャン」アクションを使用してRDDを取得しました。 このRDDの各項目は次のようである:X1、Y1、Y2、Y3 ... (各ラインはスキャン動作の行結果である)ように、このRDDの項目があるので:RDD(Spark)のアイテムをRDDの多くのアイテムに変換する方法は?
- X1、Y1、私はこれを変換したいY2、Y3
- X2、Y1、Y4、Y8、Y9
- X3、Y5
- ......
- XN、Y1、Y6、Y100
RDDから別のRDDへ:
- X1、Y1
- X1、Y2
- X1、Y3
- X2、Y1
- X2、Y4
- ...
- XN、Y1
- XN、 y6
- xn、y100
この変換はどのように行うことができますか?
私ははい、それはタイプミスである第2項目はタイプミスであると仮定...そして代わりX2 –
のX1されなければなりません。私はそれを変更する。ありがとう! @JustinPihony – York