Форум программистов
 

Восстановите пароль или Зарегистрируйтесь на форуме, о проблемах и с заказом рекламы пишите сюда - alarforum@yandex.ru, проверяйте папку спам!

Вернуться   Форум программистов > IT форум > Помощь студентам
Регистрация

Восстановить пароль
Повторная активизация e-mail

Купить рекламу на форуме - 42 тыс руб за месяц

Ответ
 
Опции темы Поиск в этой теме
Старый 26.03.2017, 11:49   #1
rizhikm
 
Регистрация: 13.04.2016
Сообщений: 9
По умолчанию Scala, работа с файлами

Подскажите,пожалуйста , как делать задание :У мебя есть два файла. Один геолокация водителя и грузовика - там присутствует поле в котором хранятся происшествия и нарушения пдд водителем. Второй - пробег в милях и расход топлива на каждый день.задача:расчитать для каждого водителя фактор риска - количество происшествий за период деленное на пробег
вывести в виде driver_id milage risk_facto
Первый файл в виде
A19,A19,normal,35.373292,...
A88,A88,normal,...
Вот я пишу
val ordersRDD = sc.textFile("C:\\Users\\Home\\Downl oads\\geolocation.csv")
val ordersMapRDD = ordersRDD.map(rec => ((rec.split(",")(0), rec.split(",")(2))))
а как дальше посчитать кол-во нарушений для каждого водителя. скорее всего с помощью aggregate for,но не пойму как это сделать, так как оба столбца типа String
rizhikm вне форума Ответить с цитированием
Ответ


Купить рекламу на форуме - 42 тыс руб за месяц

Опции темы Поиск в этой теме
Поиск в этой теме:

Расширенный поиск


Похожие темы
Тема Автор Раздел Ответов Последнее сообщение
Лабораторная работа(очень простая) Структуры, работа с файлами yurda Фриланс 2 11.06.2016 08:44
Работа с файлами: запись, добавление, чтение (найти ошибку в коде) / C для начинающих Надо создать программу для работы с файлами Konlor Общие вопросы C/C++ 2 18.05.2014 12:37
Lift и Scala maomam Фриланс 0 09.01.2013 20:25