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[]) {