의사 코드 나는 다음과 같은 문제를 해결하기 위해 의사 코드에서 맵리 듀스 알고리즘을 작성하려는 맵리 듀스

Question

안녕을 사용하여 평균을 계산하는 각 우편 번호에 대한 하우스 값. 당신이 좀 도와 수 있다면 는 정말 감사하겠습니다 ..

이

Answer 1

가장 쉬운 아파치 돼지를 사용하는 것, 여기에 평균 찾는 예입니다

inpt = load 'data.txt' as (address:chararray, zip:chararray, city:chararray, house_value:long); 
grp = group inpt by zip; 
average = foreach grp generate FLATTEN(group) as (zip), AVG(inpt.house_value) as average_price; 
dump average; 

하는 의사지도 코드를 당신이 할 줄 경우를 MAPPER, COMBINER 및 REDUCER가 하나만 필요합니다.

MAPPER(record): 
    zip_code_key = record['zip']; 
    value = {1, record['house_value']}; 
    emit(zip_code_key, value); 

COMBINER(zip_code_key, value_list): 
    record_num = 0; 
    value_sum = 0; 
    foreach (value : value_list) { 
     record_num += value[0]; 
     value_sum += value[1]; 
    } 
    value_out = {record_num, value_sum}; 
    emit(zip_code_key, value_out); 

REDUCER(zip_code_key, value_list): 
    record_num = 0; 
    value_sum = 0; 
    foreach (value : value_list) { 
     record_num += value[0]; 
     value_sum += value[1]; 
    } 
    avg = value_sum/record_num; 
    emit(zip_code_key, avg);