$ pip install dpark
python
import dpark
python
sc = dpark.DparkContext()
python
rdd = sc.parallelize([1, 2, 3, 4, 5])
python
rdd2 = rdd.map(lambda x: x * 2)
python
result = rdd2.collect()
python
sc.stop()
python
import dpark
def calculate_average(numbers):
sc = dpark.DparkContext()
rdd = sc.parallelize(numbers)
average = rdd.mean()
sc.stop()
return average
numbers = [1, 2, 3, 4, 5]
average = calculate_average(numbers)
print("Average:", average)
