Карта Hadoop уменьшить Java - PullRequest
Новая
       10

Карта Hadoop уменьшить Java

0 голосов
/ 04 сентября 2018 
public static class TokenizerMapper extends Mapper<Object, Text, Text, Text> {
    public void map(Object key, Text value, Context context) throws IOException, InterruptedException {
        StringTokenizer itr = new StringTokenizer(value.toString(), " *$&#/\t\n\f\"'\\,.:;?![](){}<>~-_");
        while (itr.hasMoreTokens()) {
            String term = itr.nextToken().toLowerCase();
            List<Pair<String, Pair<Integer, Integer>>> map = new ArrayList<Pair<String, Pair<Integer, Integer>>>();
            /*here i am performing some operations*/
            for (Pair<String, Pair<Integer, Integer>> i : map){
                String w1 = i.getKey();
                Text word = new Text(w1);
                Pair<Integer, Integer> newValue = i.getValue();
                String merge = String.valueOf(newValue.getKey()) + " " + String.valueOf(newValue.getValue());
                Text val = new Text(merge);
                /*sending both the arguments as text into my context.*/
                context.write(word, val);
            }
        }
    }
}

public static class Reducer1 extends Reducer<Text, Text, Text, Text> {
    public void reduce(Text key, Text values, Context context) throws IOException, InterruptedException {
        /* here i want to extract the values, i tried using for loop but its saying cannot iterate, its expecting something iterable.*/
        for (Text t : values)
        {
            /*this is not working. I know we can use Iterable<IntWritable> for integers but in my case it is text.
        }
        //context.write(key, values);
    }
}

Пожалуйста, смотрите строки комментариев для лучшего понимания моей проблемы. Есть ли способ извлечь текстовые значения в редуктор . For цикл ожидает чего-то iterable.

1 Ответ

0 голосов
/ 04 сентября 2018

В вашем редукторе вы получите Iterable<Text>, который вы должны зациклить и разбить на пробел, чтобы воссоздать значения String для каждой строки merge, которую написал преобразователь.

Примечание. Разделение на пробелы не будет очень надежным, если newValue.getKey() на карте содержит строки

.
...