|
|
Регистрация Восстановить пароль |
Повторная активизация e-mail |
Регистрация | Задать вопрос |
Заплачу за решение |
Новые сообщения |
Сообщения за день |
Расширенный поиск |
Правила |
Всё прочитано |
|
Опции темы | Поиск в этой теме |
26.03.2017, 11:49 | #1 |
Регистрация: 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 |
Опции темы | Поиск в этой теме |
Похожие темы | ||||
Тема | Автор | Раздел | Ответов | Последнее сообщение |
Лабораторная работа(очень простая) Структуры, работа с файлами | 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 |