maxim_musin OutputFormat example in the problem description has 99 two times and it should contain only unique values.
yandrypozo The python code is wrong in a lot of things, may you fix it ?
george_jost Yes, the fix is extremely easy
Code fixes :
def execute(self, data, mapper, reducer): for line in data: record = json.loads(line) mapper(record) for key in self.intermediate: reducer(key, self.intermediate[key]) jenc = json.JSONEncoder() for item in self.result: print item[1] # Obviously, to match the output the originator expects, you have to repair the faulty print statement AND only output one number. It's up to you whether the "key" or the value if what you want output in this case. For this trivial version of map/reduce, we don't need a special value in the reducer.) # print "{\"key\":\""+item[0]+"\",\"value\":" + str(item[1]) + "}"
EDIT: Originally, I forgot, first line is number of entries. You have to ignore the first data item.
gideonaa Suggestion for the instructions (not sure if this is relevant to anyone here):
Seems like the instruction "For instance, if R = [10,20,40,20,60];you may treat it as [10,20,40,60]" should be in the Output Format section.
anamax I'm confused. The print in MapReducer.execute() (shown below) can never print a "99" - it always prints two things, wrapped into a json structure.
print "{\"key\":\""+item[0]+"\",\"value\":" + str(item[1]) + "}"
Are we supposed to modify execute() as well?
george_jost Yes, apparently. EDIT: One note, I originally missed an important requirement. Line 1, going to your data will be the number of entries. Anyway, you need to fix it. It is a good introduction to Map/Reduce which is what I wanted to get out of the exercise
nicoleneo Test Case #2 fails. I only print unique odd values > 10 .
sam_alizadeh you probably forgot to filter out the first number which is the numnber of lines that comes after.
nicoleneo Bingo! It worked.
muneeb2405 How can i filter out first value??
nicoleneo If stdin linenum == 0, store that as N, else read them as values.
muneeb2405 i didnot understand that !!i cant get it
nicoleneo inputData = [] counter = 0 for line in sys.stdin: if (counter == 0): N = int(line) else: inputData.append(json.dumps({"key":counter,"value":line})) counter += 1 mapReducer.execute(inputData, mapper, reducer)
BigJin Brilliant!
george_jost I can't seem to upvote your helpful reply
george_jost [deleted]
No more comments
Sort 5 Discussions, By:
Please Login in order to post a comment