Please find this program .. may be this will be the solution....These are related to map reduce .... import MapReduce import sys
""" Word Count Example in the Simple Python MapReduce Framework """
mr = MapReduce.MapReduce()
# ============================= # Do not modify above this line def mapper(record): # key: document identifier # value: document contents trim_nucleotid = record[1][:-10] mr.emit_intermediate(trim_nucleotid, 1 )
def reducer(trim_nucleotid, list_of_values): # key: word # value: list of occurrence counts #mr.emit((person,len(list_of_values)) ) mr.emit(trim_nucleotid)
# Do not modify below this line # ============================= if __name__ == '__main__': inputdata = open(sys.argv[1]) mr.e xecute(inputdata, mapper, reducer)
Comment
Please find this program .. may be this will be the solution....These are related to map reduce ....
import MapReduce
import sys
"""
Word Count Example in the Simple Python MapReduce Framework
"""
mr = MapReduce.MapReduce()
# =============================
# Do not modify above this line
def mapper(record):
# key: document identifier
# value: document contents
trim_nucleotid = record[1][:-10]
mr.emit_intermediate(trim_nucleotid, 1 )
def reducer(trim_nucleotid, list_of_values):
# key: word
# value: list of occurrence counts
#mr.emit((person,len(list_of_values)) )
mr.emit(trim_nucleotid)
# Do not modify below this line
# =============================
if __name__ == '__main__':
inputdata = open(sys.argv[1])
mr.e xecute(inputdata, mapper, reducer)
Replies
What is this related to?