官术网_书友最值得收藏!

.sortByKey(...) transformation

The sortByKey(asc) transformation orders (key, value) RDD by key and returns an RDD in ascending or descending order. Look at the following code snippet:

# Takes the origin code and delays, remove header
# runs a group by origin code via reduceByKey()
# sorting by the key (origin code)
(
flights
.zipWithIndex()
.filter(lambda (row, idx): idx > 0)
.map(lambda (row, idx): row)
.map(lambda c: (c[3], int(c[1])))
.reduceByKey(lambda x, y: x + y)
.sortByKey()
.take(50)
)

This will produce this output:

# Output
[(u'ABE', 5113),
(u'ABI', 5128),
(u'ABQ', 64422),
(u'ABY', 1554),
(u'ACT', 392),
...]
主站蜘蛛池模板: 眉山市| 曲水县| 鄂尔多斯市| 东明县| 淄博市| 清水河县| 大兴区| 沙雅县| 当涂县| 乌什县| 辉县市| 卓尼县| 四子王旗| 朝阳市| 四子王旗| 潞西市| 上思县| 江源县| 长沙市| 建水县| 霍邱县| 渑池县| 南部县| 寻甸| 买车| 天镇县| 乌拉特中旗| 永福县| 南溪县| 万年县| 行唐县| 浦城县| 宜春市| 磐安县| 汤原县| 东辽县| 普洱| 昭苏县| 舟曲县| 东源县| 龙川县|