Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- /*Инициализируйте объект 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))
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement