Инициализируйте объект SparkContext. Укажите параметр appName равный 'appName'. Создайте переменную weather_entry (англ. «запись о погоде»), в которой сохраните RDD с такими элементами:
- дата заказа —
2009-01-01; - самая низкая температура воздуха в этот день (°C) —
15.1; - самая высокая температура воздуха в этот день (°C) —
26.1.
Выведите на экран содержимое RDD. Для этого вызовите метод take() (англ. «взять»). Посмотрите в документации, как он работает.
from pyspark import SparkContext
sc = SparkContext(appName="appName")
weather_entry = sc.parallelize(['2009-01-01', 15.1, 26.1])
print(weather_entry.take(3))Результат [Stage 0:> (0 + 1) / 1]
['2009-01-01', 15.1, 26.1]
Вы научились извлекать содержимое из RDD! В такую-то погоду и такси можно не вызывать.