0
我最初的RDD; Array [Array [String]],如下所示:如何從RDD(Array [String])創建RDD(子數組[String])?
a b h c ....... d e x q
d r d x ....... e q g m
f e u t ....... q t g y
a b h c ....... d e x q
d r d x ....... e q g m
f e u t ....... q t g y
....
....
新的RDD; Array [Array [String]],其中包含:
u t ...... q t
h c ...... d e
有關如何使用它的任何想法?數組的大小很大,所以可能需要任何大小的子數組。 在此先感謝。
如果你有函數'bigToSmallArray',那麼你只需要'rdd ofSmallArrays = rddOfBigArrays.map(bigToSmallArray)' – abalcerek