From 2e9c6812500e939572ad91e23f052c9b28bf60bf Mon Sep 17 00:00:00 2001 From: Remzi Arpaci-Dusseau Date: Wed, 11 Apr 2018 15:33:00 -0500 Subject: [PATCH] getter fix --- concurrency-mapreduce/README.md | 4 ++-- concurrency-mapreduce/mapreduce.h | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/concurrency-mapreduce/README.md b/concurrency-mapreduce/README.md index e539858..e56f463 100644 --- a/concurrency-mapreduce/README.md +++ b/concurrency-mapreduce/README.md @@ -99,7 +99,7 @@ header file that specifies exactly what you must build in your MapReduce library #define __mapreduce_h__ // Various function pointers -typedef char *(*Getter)(); +typedef char *(*Getter)(char *key); typedef void (*Mapper)(char *file_name); typedef void (*Reducer)(char *key, Getter get_func, int partition_number); typedef unsigned long (*Partitioner)(char *key, int num_buckets); @@ -161,7 +161,7 @@ void Map(char *file_name) { void Reduce(char *key, Getter get_next, int partition_number) { int count = 0; char *value; - while ((value = get_next(partition_number)) != NULL) + while ((value = get_next(key)) != NULL) count++; printf("%s %d\n", key, count); } diff --git a/concurrency-mapreduce/mapreduce.h b/concurrency-mapreduce/mapreduce.h index 49c2cdc..ab867cd 100644 --- a/concurrency-mapreduce/mapreduce.h +++ b/concurrency-mapreduce/mapreduce.h @@ -1,7 +1,7 @@ #ifndef __mapreduce_h__ #define __mapreduce_h__ -typedef char *(*Getter)(); +typedef char *(*Getter)(char *key); typedef void (*Mapper)(char *file_name); typedef void (*Reducer)(char *key, Getter get_func, int partition_number);