mapreduce

1зной

2ответ

ArrayIndexOutofBoundsException с Hadoop MapReduce

Я получаю ArrayIndexOutofBoundsException рядом с String temp = word[5]; в моем картографе. Я исследовал это, и я знаю, что ошибка происходит из (когда входные данные пуст или длина меньше или больше п

2зной

1ответ

Как построить метод buildOutputValue

Пожалуйста, мне нужна помощь в этом коде: public class ThirdQueryReducer extends Reducer<IntWritable, Text, NullWritable, Text> { private NullWritable nullWritableKey = NullWritable.get(); pri

0зной

1ответ

MongoDB: Операция Aggregation Group над динамической парой ключ-значение

У меня есть простой документ с одним полем как пара ключ-значение. Я хочу просто выполнить групповую операцию в Агрегации над этими ключами и добавить их значения. Но ключи в паре не фиксированы и мог

1зной

2ответ

Передача аргументов для запроса на удержание

Я пытаюсь передать аргументы командной строки ниже, но не работает. Может ли кто-нибудь помочь мне с тем, что я делаю неправильно здесь! hive -f test2.hql -hiveconf partition=20170117 -hiveconf -hivec

0зной

1ответ

Pig Script Генерирующие Тысячи Карты

По какой-то причине этот скрипт нерест 60000 рабочих мест на карте на небольшой вход: A1 = LOAD '$directory1' USING CustomLoader AS key:chararray; A = FOREACH A1 GENERATE CustomParser(key) AS key:cha

0зной

1ответ

Count Duplicates Значения в течение интервала времени в PySpark

Я работаю над заданием PySpark с большими данными в формате ниже. ID-1234567 iplong agent partner client country timestamp category reference Мне нужно найти среднее количество повторяющихся записей

1зной

1ответ

Что означает «время, затраченное на выполнение задачи карты», на Hadoop?

После выполнения задания Hadoop краткое изложение показанных счетчиков приведено ниже. Мой вопрос будет заключаться в том, что включено в счетчик Total time spent by all map tasks, в частности, в случ