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

.distinct() transformation

The distinct() transformation returns a new RDD containing the distinct elements of the source RDD. So, look at the following code snippet:

# Provide the distinct elements for the 
# third column of airports representing
# countries
(
airports
.map(lambda c: c[2])
.distinct()
.take(5)
)

This will return the following output:

# Output
[u'Canada', u'USA', u'Country']
主站蜘蛛池模板: 岳普湖县| 化隆| 华池县| 德惠市| 天津市| 林芝县| 汕头市| 正安县| 睢宁县| 特克斯县| 桐城市| 汾西县| 万荣县| 东乡族自治县| 扶风县| 济源市| 巫山县| 定西市| 将乐县| 毕节市| 通辽市| 新昌县| 永川市| 泾川县| 浮山县| 固镇县| 陆川县| 广河县| 临安市| 乐山市| 白朗县| 安达市| 壶关县| 龙江县| 自治县| 霍林郭勒市| 平远县| 康乐县| 道孚县| 虞城县| 随州市|