我有一个如下的RDD:
RDD[(String, Int, String)]
作为一个例子:
('b', 1, 'a')
('a', 1, 'b')
('a', 0, 'b')
('a', 0, 'a')
最终结果应该类似于:
('a', 0, 'a')
('a', 0, 'b')
('a', 1, 'b')
('b', 1, 'a')
我该怎么做到像这样呢?
我有一个如下的RDD:
RDD[(String, Int, String)]
('b', 1, 'a')
('a', 1, 'b')
('a', 0, 'b')
('a', 0, 'a')
('a', 0, 'a')
('a', 0, 'b')
('a', 1, 'b')
('b', 1, 'a')
试试这个:
rdd.sortBy(r => r)
rdd.sortBy(r => (r._3, r._1, r._2))
逆序排列:
rdd.sortBy(r => r, false)