Advertisement
Step8rother

Spark и RDD, задача 1

Jun 29th, 2023 (edited)
955
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
SQL 0.91 KB | Source Code | 0 0
  1. /*Инициализируйте объект SparkContext. Укажите параметр appName равный 'appName'. Создайте переменную weather_entry (англ. «запись о погоде»), в которой сохраните RDD с такими элементами:
  2. дата заказа — 2009-01-01;
  3. самая низкая температура воздуха в этот день (°C) — 15.1;
  4. самая высокая температура воздуха в этот день (°C) — 26.1.
  5. Выведите на экран содержимое RDD. Для этого вызовите метод take() (англ. «взять»). Посмотрите в документации, как он работает.
  6. */
  7.  
  8. FROM pyspark import SparkContext
  9.  
  10. sc = SparkContext(appName='appName')
  11. weather_entry = sc.parallelize(['2009-01-01', 15.1, 26.1])
  12. print(weather_entry.take(3))
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement