/Python/Return a new RDD by applying a function to each element of this RDD.

Return a new RDD by applying a function to each element of this RDD.

Return a new RDD by applying a function to each element of this RDD.

rdd = sc.parallelize(["b", "b", "c"])
sorted(rdd.map(lambda x: (x, 1)).collect())
# [('a', 1), ('b', 1), ('c', 1)]

0

Source: spark.apache.org

Similar codes

22 votes138 views3 answers
How to call a random function in python
Python
0 vote144 views1 answer
How to convert categorical data to binary data in python
Python
0 vote151 views1 answer
Pythom sum
Python
0 vote177 views1 answer
Django multi column index
Python Django
39 votes143 views5 answers
Csv to python
Python
0 vote145 views1 answer
Inverted trapezium pattern in python
Python
7 votes101 views1 answer
Data frame do nympy
Python
23 votes144 views6 answers
Odd or even python
Python
1 vote154 views4 answers
Django query or condition for query parameters
Python
3 votes125 views1 answer
Get range of items of python list
Python

Share