mapreduce

0зной

1ответ

CouchDB - совокупность нескольких значений на этапе уменьшения

Я пытаюсь объединить несколько значений, испускаемых с моей карты, в пользовательской функции сокращения (rereduce enabled), но я получаю нулевые значения в результате, за исключением нескольких точек

0зной

1ответ

Суммировать значение индекса в нескольких массивах с pyspark

У меня есть массив 50 с поплавковыми значениями (50*7). Как я могу представить себе 50 массивов по одному и тому же индексу с функцией редуктора PySpark. Пример: array1 = {1,2,3,4,5,6,7} array2 = {3,

0зной

1ответ

Ограничение выхода от редуктора в Map уменьшить API

В моей программе mapreduce выход моего редуктора производит 1 миллион строк вывода, но мне нужны только первые первые 3 вывода. И для этого я поддерживаю переменную экземпляра в моем классе Reducer, к

0зной

2ответ

Ошибка в классе Driver в Java Mapreducer

Я получаю ошибку в обработке job.setInputFormatClass(TextInputFormat.class); job.setOutputFormatClass(TextOutputFormat.class); Как справиться с этим? Кто-нибудь может мне помочь, пожалуйста...! imp

2зной

2ответ

Основы Hadoop и MapReduce функционирующий

Я только начал изучать Hadoop и Map-Reduce концепции и имеют следующие несколько вопросов, которые я хотел бы списываться прежде чем двигаться вперед: Из того, что я понимаю: Hadoop специально использ

2зной

1ответ

В hadoop, что подразумевается под умением сохранять состояние через редуктор Mapper несколькими входами?

Заголовок вопроса объясняет все, что касается моего вопроса. я читал через несколько текстов, ответы, где я наткнулся на эту линию Благодаря использованию объединителя и воспользовавшись возможностью

2зной

1ответ

Сравнение Hadoop Text не работает

Ниже приведен код для Hadoop Reducer, я не могу понять, почему сравнение (между косами) всегда терпит неудачу, здесь мы сравниваем два значения типа Text. Этот код предназначен для редуктора, делающег