mapreduce

0зной

1ответ

Мониторинг CPU core runnning Задачи Hadoop

Возможно ли контролировать (просматривать) нагрузку каждого ядра обработки при запуске кода Hadoop MapReduce? Я использую ноутбук с Ubuntu и Intel® Core ™ 2 Duo CPU U9600 @ 1,60 × 2.

2зной

1ответ

Что такое принцип «переход кода к данным», а не данные в код?

В недавней дискуссии о распределенной обработке и потоковой передаче я сталкиваюсь с тем, что там отображается код, перемещающийся к данным. Может кто-то, пожалуйста, помогите объяснить то же самое. С

1зной

2ответ

InvocationTargetException в пряжи задачи с Hadoop

Во время работы Kafka ->Apache Apex ->Hbase, он говорит следующее исключение в задачах пряжи: com.datatorrent.stram.StreamingAppMasterService: Application master, appId=4, clustertimestamp=14791888841

0зной

2ответ

Создайте таблицу HBase из формата файла CSV программно и загрузите его содержимое

Привет, я довольно новичок в hadoop, и я пытаюсь импортировать таблицу csv в Hbase с помощью MapReduce. Я использую Cloudera 5.9 я хотел бы firsly создать таблицу Hbase программно из формата таблицы C

2зной

1ответ

Невозможно вставить новые данные в HBase при использовании Delete и Put в то же время

Я использую Hbase mapreduce для расчета отчета. В редукторе я пытаюсь очистить семейство столбцов «результат», а затем добавить новый «итоговый» столбец. Но я считаю, что семейство столбцов удаляется,

0зной

2ответ

FAILED Ошибка: java.io.IOException: Инициализация всех коллекционеров завершилась неудачно

Я получаю некоторую ошибку при запуске моей работы MapReduce WordCount. Error: java.io.IOException: Initialization of all the collectors failed. Error in last collector was :class wordcount.wordmapper

2зной

1ответ

Как получить разницу между двумя RDD в PySpark?

Я пытаюсь создать исследование когорты для отслеживания в приложении поведения пользователя, и я хочу спросить, если у вас есть какие-либо идеи о том, как я могу исключить элемент из РДА 2, который на