Пишу программу, используя Hadoop MapReduce.
Что-то совсем запутался с тем, как написать методы map и reduce, так, чтобы они работать со следующей задачей:
Входной файл имеет следующий вид:
1 2
1 3
1 4
2 3
4 3
...
Здесь просто список вершин. Напремер "1 2" - т.е. есть направленное ребро из вершины 1 в вершину 2 (разделены табуляцией).
Нужно найти вершины с наибольшим числом "входящих" ребер и найти среднюю степень вершины в графе (для каждой вершины средняя степень = количество "входящий" ребер / общее число ребер) Не пойму как написать mapper и reducer...
Вообще хочу иметь дело с таким объектом: (vertice_number, incomming_edge_number)
- vertice_number
- номер вершины
- incomming_edge_number
- число входящих ребер