lostecho/ostep-projects
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

getter fix

Browse Source
This commit is contained in:
Remzi Arpaci-Dusseau
2018-04-11 15:33:00 -05:00
parent e9b0ccd03b
commit 2e9c681250
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
concurrency-mapreduce/README.md
View File

@@ -99,7 +99,7 @@ header file that specifies exactly what you must build in your MapReduce library
#define __mapreduce_h__ #define __mapreduce_h__
// Various function pointers // Various function pointers
typedef char *(*Getter)(); typedef char *(*Getter)(char *key);
typedef void (*Mapper)(char *file_name); typedef void (*Mapper)(char *file_name);
typedef void (*Reducer)(char *key, Getter get_func, int partition_number); typedef void (*Reducer)(char *key, Getter get_func, int partition_number);
typedef unsigned long (*Partitioner)(char *key, int num_buckets); 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) { void Reduce(char *key, Getter get_next, int partition_number) {
int count = 0; int count = 0;
char *value; char *value;
while ((value = get_next(partition_number)) != NULL) while ((value = get_next(key)) != NULL)
count++; count++;
printf("%s %d\n", key, count); printf("%s %d\n", key, count);
} }

2
concurrency-mapreduce/mapreduce.h
View File

@@ -1,7 +1,7 @@
#ifndef __mapreduce_h__ #ifndef __mapreduce_h__
#define __mapreduce_h__ #define __mapreduce_h__
typedef char *(*Getter)(); typedef char *(*Getter)(char *key);
typedef void (*Mapper)(char *file_name); typedef void (*Mapper)(char *file_name);
typedef void (*Reducer)(char *key, Getter get_func, int partition_number); typedef void (*Reducer)(char *key, Getter get_func, int partition_number);