diff options
author | Andrea Smith <smit9523@umn.edu> | 2020-10-05 20:23:32 -0500 |
---|---|---|
committer | Andrea Smith <smit9523@umn.edu> | 2020-10-05 20:23:32 -0500 |
commit | ce72bbe5d420797677e40e44d4529c4910bfe779 (patch) | |
tree | 93f0aac36299f5d5028e89ab54852ca06420621d /P1 | |
parent | Update comments (diff) | |
parent | Merge branch 'master' of github.umn.edu:STRAP012/csci4061Projects (diff) | |
download | csci4061-ce72bbe5d420797677e40e44d4529c4910bfe779.tar csci4061-ce72bbe5d420797677e40e44d4529c4910bfe779.tar.gz csci4061-ce72bbe5d420797677e40e44d4529c4910bfe779.tar.bz2 csci4061-ce72bbe5d420797677e40e44d4529c4910bfe779.tar.lz csci4061-ce72bbe5d420797677e40e44d4529c4910bfe779.tar.xz csci4061-ce72bbe5d420797677e40e44d4529c4910bfe779.tar.zst csci4061-ce72bbe5d420797677e40e44d4529c4910bfe779.zip |
Merge branch 'master' of github.umn.edu:STRAP012/csci4061Projects
Diffstat (limited to 'P1')
-rw-r--r-- | P1/include/mapper.h | 1 | ||||
-rw-r--r-- | P1/include/utils.h | 1 | ||||
-rw-r--r-- | P1/src/reducer.c | 14 |
3 files changed, 8 insertions, 8 deletions
diff --git a/P1/include/mapper.h b/P1/include/mapper.h index bbc6ef1..2e3693c 100644 --- a/P1/include/mapper.h +++ b/P1/include/mapper.h @@ -6,7 +6,6 @@ // ###### DO NOT REMOVE ###### #define MAXKEYSZ 100 #define MAXVALUESZ 100 -#define BUFFSIZE 150 // ###### DO NOT REMOVE ###### char *mapOutDir; diff --git a/P1/include/utils.h b/P1/include/utils.h index cfe56f2..da5ffd8 100644 --- a/P1/include/utils.h +++ b/P1/include/utils.h @@ -18,6 +18,7 @@ #define MSGSIZE 1100 #define ENDTYPE 1000 #define ACKTYPE 1100 +#define BUFFSIZE 150 struct msgBuffer { long msgType; diff --git a/P1/src/reducer.c b/P1/src/reducer.c index 8656629..9519fa3 100644 --- a/P1/src/reducer.c +++ b/P1/src/reducer.c @@ -51,20 +51,20 @@ void reduce(char *key) { // write the contents of the final intermediate structure // to output/ReduceOut/Reduce_reducerID.txt void writeFinalDS(int reducerID){ - + finalKeyValueDS *root = &DS; - finalKeyValueDS *tempNode = root; + finalKeyValueDS *tempNode = root -> next; while(tempNode != NULL) { - // Shove word and ones in a file named word.txt - char filename[150]; - sprintf(filename, "output/MapOut/Map_%d/%s.txt", reducerID, tempNode -> key); + // Shove word and number of occurances in a file named word.txt + char filename[BUFFSIZE] = ""; + sprintf(filename, "output/ReduceOut/Reduce_%d.txt", reducerID); FILE* fptr = fopen(filename, "w"); - fprintf(fptr, "%s %d", tempNode -> key, tempNode -> value); + fprintf(fptr, "%s %s", tempNode -> key, tempNode -> value); fclose(fptr); tempNode = tempNode -> next; } - freeFinalDS(root); + freeInterDS(root -> next); } int main(int argc, char *argv[]) { |