Difference between revisions of "CSC352 Game of Life in Map-Reduce"
| Line 1: | Line 1: | ||
--[[User:Thiebaut|D. Thiebaut]] ([[User talk:Thiebaut|talk]]) 16:47, 2 April 2017 (EDT) | --[[User:Thiebaut|D. Thiebaut]] ([[User talk:Thiebaut|talk]]) 16:47, 2 April 2017 (EDT) | ||
---- | ---- | ||
| − | + | ||
=Reference= | =Reference= | ||
<br /> | <br /> | ||
| Line 286: | Line 286: | ||
| − | |||
<br /> | <br /> | ||
<br /> | <br /> | ||
Revision as of 08:54, 21 April 2017
--D. Thiebaut (talk) 16:47, 2 April 2017 (EDT)
Contents
Reference
- Using MapReduce Streaming for Distributed Life Simulation on the Cloud, by Atanas Radenski.
Introduction
- We map-reduce once to go from one generation to the next.
- The original array (see Data File section below) is transformed into a file where each line is numbered, and each row of the game of life is sandwiched between double quotes.
- To go from the data file to the first generation:
cat life0.txt | ./mapper.py | ./shuffleSort.py | ./reducer.py 2 4 2 5 2 6
- the output is a horizontal line, on Row 2, spanning Columns 4, 5, and 6.
- To generate the second generation:
cat life0.txt | ./mapper.py | ./shuffleSort.py | ./reducer.py | ./mapper.py | ./shuffleSort.py | ./reducer.py 1 5 2 5 3 5
- To generate the third generation:
cat life0.txt | ./mapper.py | ./shuffleSort.py | ./reducer.py | ./mapper.py | ./shuffleSort.py | ./reducer.py \ | ./mapper.py | ./shuffleSort.py | ./reducer.py 2 4 2 5 2 6
Data File
The file is called life0.txt.
0 " " 1 " * " 2 " * " 3 " * " 4 " "
Mapper.py
#!/usr/bin/env python from __future__ import print_function import sys # input comes from STDIN (standard input) for line in sys.stdin: # remove leading and trailing whitespace line = line.strip() #print( "line =", line ) # split the line into words words = line.split( None, 1 ) #print( "words = ", words ) isRawLife = line.find( "\"" ) != -1 # are we reading the original array of cells from a file? if isRawLife: lineNo = int( words[0] ) lineWidth = len( words[1] )-2 # for the double quotes lifeLine = words[1].replace( "\"", "" ) #print( "(%d, >%s<)" % ( lineNo, lifeLine ) ) for j in range( len( lifeLine ) ): if lifeLine[j] != ' ': print( "%03d%03d\t%s" % ( lineNo, j, "alive" ) ) for row in range( lineNo-1, lineNo+1+1 ): for col in range( j-1, j+1+1 ): if row < 0: continue if col < 0: continue if col > lineWidth: col = 0 if row == lineNo and col == j: continue print( "%03d%03d\t%s" % ( row, col, "OneMoreNeighbor" ) ) # or are we reading tuples output by the reducer? else: lineNo = int( words[0] ) j = int( words[1] ) print( "%03d%03d\t%s" % ( lineNo, j, "alive" ) ) for row in range( lineNo-1, lineNo+1+1 ): for col in range( j-1, j+1+1 ): if row < 0: continue if col < 0: continue if row == lineNo and col == j: continue print( "%03d%03d\t%s" % ( row, col, "OneMoreNeighbor" ) )
Mapper on Original Life File
cat life0.txt | ./mapper.py 001005 alive 000004 OneMoreNeighbor 000005 OneMoreNeighbor 000006 OneMoreNeighbor 001004 OneMoreNeighbor 001006 OneMoreNeighbor 002004 OneMoreNeighbor 002005 OneMoreNeighbor 002006 OneMoreNeighbor 002005 alive 001004 OneMoreNeighbor 001005 OneMoreNeighbor 001006 OneMoreNeighbor 002004 OneMoreNeighbor 002006 OneMoreNeighbor 003004 OneMoreNeighbor 003005 OneMoreNeighbor 003006 OneMoreNeighbor 003005 alive 002004 OneMoreNeighbor 002005 OneMoreNeighbor 002006 OneMoreNeighbor 003004 OneMoreNeighbor 003006 OneMoreNeighbor 004004 OneMoreNeighbor 004005 OneMoreNeighbor 004006 OneMoreNeighbor
Mapper on Output of Reduce
cat life0.txt | ./mapper.py | ./shuffleSort.py | ./reducer.py | ./mapper.py 002004 alive 001003 OneMoreNeighbor 001004 OneMoreNeighbor 001005 OneMoreNeighbor 002003 OneMoreNeighbor 002005 OneMoreNeighbor 003003 OneMoreNeighbor 003004 OneMoreNeighbor 003005 OneMoreNeighbor 002005 alive 001004 OneMoreNeighbor 001005 OneMoreNeighbor 001006 OneMoreNeighbor 002004 OneMoreNeighbor 002006 OneMoreNeighbor 003004 OneMoreNeighbor 003005 OneMoreNeighbor 003006 OneMoreNeighbor 002006 alive 001005 OneMoreNeighbor 001006 OneMoreNeighbor 001007 OneMoreNeighbor 002005 OneMoreNeighbor 002007 OneMoreNeighbor 003005 OneMoreNeighbor 003006 OneMoreNeighbor 003007 OneMoreNeighbor
ShufflerSort.py
#!/usr/bin/env python from __future__ import print_function import sys sortNumeric = False if len( sys.argv ) > 1 and sys.argv[1] == "-n": sortNumeric = True L = [] # input comes from STDIN for line in sys.stdin: # remove leading and trailing whitespace line = line.strip() word, count = line.split('\t', 1) if sortNumeric: word = int( word ) L.append( (word, count) ) L.sort() for word, count in L: print( '%s\t%s' % (word, count) )
Output of ShuffleSort
cat life0.txt | ./mapper.py | ./shuffleSort.py 000004 OneMoreNeighbor 000005 OneMoreNeighbor 000006 OneMoreNeighbor 001004 OneMoreNeighbor 001004 OneMoreNeighbor 001005 OneMoreNeighbor 001005 alive 001006 OneMoreNeighbor 001006 OneMoreNeighbor 002004 OneMoreNeighbor 002004 OneMoreNeighbor 002004 OneMoreNeighbor 002005 OneMoreNeighbor 002005 OneMoreNeighbor 002005 alive 002006 OneMoreNeighbor 002006 OneMoreNeighbor 002006 OneMoreNeighbor 003004 OneMoreNeighbor 003004 OneMoreNeighbor 003005 OneMoreNeighbor 003005 alive 003006 OneMoreNeighbor 003006 OneMoreNeighbor 004004 OneMoreNeighbor 004005 OneMoreNeighbor 004006 OneMoreNeighbor
Reducer.py
#!/usr/bin/env python from __future__ import print_function from operator import itemgetter import sys lastCell = None isAlive = False cell = None noNeighbors = 0 # input comes from STDIN for line in sys.stdin: # remove leading and trailing whitespace line = line.strip() # parse the input we got from mapper.py cell, status = line.split('\t', 1) if cell != lastCell: # decide of fate of last cell if isAlive and 2 <= noNeighbors <= 3: # continue living print( "%d\t%d" % ( int( lastCell )/1000, int( lastCell )%1000 ) ) if not isAlive and noNeighbors == 3: # be born print( "%d\t%d" % ( int( lastCell )/1000, int( lastCell )%1000 ) ) noNeighbors = 0 isAlive = False # parse status of new cell if status.find( "alive" ) != -1: isAlive = True else: noNeighbors += 1 lastCell = cell # do not forget to output the last cell if needed! if isAlive and 2 <= noNeighbors <= 3: # continue living print( "%d\t%d" % ( int( lastCell )/1000, int( lastCell )%1000 ) ) if not isAlive and noNeighbors == 3: # be born print( "%d\t%d" % ( int( lastCell )/1000, int( lastCell )%1000 ) )
Output of Reducer
cat life0.txt | ./mapper.py | ./shuffleSort.py | ./reducer.py 2 4 2 5 2 6
