aboutsummaryrefslogtreecommitdiffstats
path: root/P1
diff options
context:
space:
mode:
Diffstat (limited to '')
-rw-r--r--P1/src/reducer.c17
1 files changed, 16 insertions, 1 deletions
diff --git a/P1/src/reducer.c b/P1/src/reducer.c
index 7afb9ee..4d501dd 100644
--- a/P1/src/reducer.c
+++ b/P1/src/reducer.c
@@ -1,5 +1,7 @@
#include "reducer.h"
+fianlKeyValueDS DS;
+
// create a key value node
finalKeyValueDS *createFinalKeyValueNode(char *word, int count){
finalKeyValueDS *newNode = (finalKeyValueDS *)malloc (sizeof(finalKeyValueDS));
@@ -49,7 +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;
+
+ 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);
+ FILE* fptr = fopen(filename, "w");
+ fprintf(fptr, "%s %d", tempNode -> key, tempNode -> value);
+ fclose(fptr);
+ tempNode = tempNode -> next;
+ }
+ freeFinalDS(root);
}
int main(int argc, char *argv[]) {