Benötigen Sie Hilfe bei diesem mapreduce Code

Question

Below is the data 

c1   p1  q1  d1 

c2   p2  q2  d2 

Ausgabe lösen müssen wie- wenn der Kunde p1 hat es kaufen flag as 1 sonst geben sollte es sollte flag 0 geben. Es gibt Millionen von Kunden und Millionen von Produkten. Unten ist die erforderliche Ausgabe. Jede Hilfe wird sehr geschätzt.

c1 p1 q1 d1 1 

c1 p2 q1 d1 0 

c2 p2 q2 d2 1 

c2 p1 q2 d2 0 

Answer 1

können Sie es mit nur einem mapside Logik erreichen, Beispielcode für Ihre Referenz:

public void map(LongWritable key, Text value, Context context) 
     throws IOException, InterruptedException { 
    String line = value.toString(); 
    NullWritable value = NullWritable.get(); 
    String tokens[] = line.split("<your delim>"); 
    if (tokens[1] == "p1") { 
     line = line + "<your delim>" + "1"; 
    } else if (tokens[1] == "p2") { 
     line = line + "<your delim>" + "0"; 
    } 
    context.write(newText(line), value); 
}