Reducer-Code zum Gruppieren der Wörter nach ihrer Länge

Question

In MapReduce-Programm, Reducer-Methode nimmt eine Eingabeform Mapper als "Wörter" und es ist Länge.

ex.input :- 
     Hi -2 
     how - 3 
     are -3 
     you - 3 
     ? - 1 

Jetzt brauche ich einen Reducer so zu schreiben, dass es durch die Gruppierung „Wortlänge“ einen Ausgang gibt und alle Wörter unter auf der Grundlage des Wortes in einer Kategorie kommt‘Länge wie unten

ex. Output :- 
     1 - [?] 
     2 - [hi] 
     3 - [how, are, you] 

Hier ist mein Mapper Programm:

public void map(LongWritable key, Text values, OutputCollector<Text, IntWritable> Output, Reporter arg3) throws IOException { 
    String s = values.toString(); 

    for (String word : s.split(" ")) { 
     if (word.length() > 0) { 
      Output.collect(new Text(word), new IntWritable(word.length())); 
     } 

    } 
} 

Wie ein Programm reduzieren wird?

Answer 1

Wenn Sie Ihre Minderer Gruppe durch die Länge wollen, müssen Sie den Mapper haben müssen emittieren, um die Länge als Schlüssel und die Wörter, wie Werte, also statt:

 Hi -2 
    how - 3 
    are -3 
    you - 3 
    ? - 1 

emittieren

 2 - Hi 
    3 - how 
    3 - are 
    3 - you 
    1 - ? 

Dann haben Sie bereits das fertige Ergebnis als Eingabe für den Reducer. Je nach System, das Sie verwenden, können Sie den Reduzierer insgesamt ausschalten oder eine einfache Identitätsfunktion verwenden.