diff options
| -rw-r--r-- | P1/src/mapper.c | 36 |
1 files changed, 16 insertions, 20 deletions
diff --git a/P1/src/mapper.c b/P1/src/mapper.c index d0db9a0..2379264 100644 --- a/P1/src/mapper.c +++ b/P1/src/mapper.c @@ -99,28 +99,24 @@ void map(char *chunkData){ // Each file will have only one line : word 1 1 1 1 1 ... // 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; + intermediateDS *tempNode = &DS; + valueList *tempNode2; + + while(tempNode != NULL) { + // Get string of 1's associated with the word + char ones[100]; + tempNode2 = tempNode2 -> value; + while(tempNode2 != NULL) { + strcat(ones, "1 "); + tempNode2 = tempNode -> next; + } - // Traverse valueList - tempNode2 = tempNode2 -> value; - while(tempNode2 != NULL) { - - tempNode2 = tempNode -> next; + // Shove word and ones in a file named word.txt + char filename[20]; + sprintf(filename, "output/map_%d/%s.txt", mapperID, tempNode -> key); + FILE* fptr = fopen(filename, "w"); + tempNode = 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[]) { |