aboutsummaryrefslogtreecommitdiffstats
path: root/P1
diff options
context:
space:
mode:
Diffstat (limited to '')
-rw-r--r--P1/src/mapper.c27
1 files changed, 25 insertions, 2 deletions
diff --git a/P1/src/mapper.c b/P1/src/mapper.c
index 3e0307d..d0db9a0 100644
--- a/P1/src/mapper.c
+++ b/P1/src/mapper.c
@@ -1,5 +1,7 @@
#include "mapper.h"
+intermediateDS DS;
+
// combined value list corresponding to a word <1,1,1,1....>
valueList *createNewValueListNode(char *value){
valueList *newNode = (valueList *)malloc (sizeof(valueList));
@@ -78,7 +80,7 @@ while (root != NULL) {
// emit the <key, value> into intermediate DS
// eats the data into the DS
void emit(char *key, char *value) {
-
+ insertPairToInterDS(&DS, key, value);
}
// map function
@@ -95,9 +97,30 @@ void map(char *chunkData){
// write intermediate data to separate word.txt files
// Each file will have only one line : word 1 1 1 1 1 ...
-// poops the data out into separate .txt files
+// poops the data out into separate .txt files named after the word
void writeIntermediateDS() {
+ // Iterate through intermediate DS
+ // Create new word.txt
+ // Insert <word, value list>
+
+ intermediateDS *tempNode = DS;
+ intermediateDS *tempNode2 = DS;
+
+ // Traverse valueList
+ tempNode2 = tempNode2 -> value;
+ while(tempNode2 != NULL) {
+
+ tempNode2 = tempNode -> next;
+ }
+
+ // while(tempNode != NULL) {
+ // char filename[20];
+ // sprintf(filename, "%s.txt", foo);
+ // FILE* fptr = fopen("%s.txt", "w");
+
+ // tempNode = tempNode -> next;
+ // }
}
int main(int argc, char *argv[]) {