while loop in dumbo

[Vincenzo De Leo]

Dear Dumbo users,

I'd like to know if there is any way to modify this simple working code that increment the value variable of 1 unit each time that a map/reduce step is executed:

class mapper:

    def __init__(self):

        pass

    def __call__(self,key,value):

        if key==0:

            yield 1,1

        else:

            value = value + 1

            yield 1,value

class reducer:

    def __init__(self):        

        pass

    def __call__(self,key,value):

        yield key,value.next()

def runner(job):

    for i in range(10):

        job.additer(mapper, reducer)        

    

if __name__ == "__main__":

    import dumbo

    dumbo.main(runner)

changing the "for loop" in a "while loop" because I have to implement a code where the number of map/reduce steps it is not known a priori but it depends from the value of a variable stored in the (key,value) couple that is updated each map/reduce step.

Thanks to all,

Best!

Vincenzo

[A Srivastava]

Hi Vincenzo,

Were you able to figure this out? I am having the same doubt while implementing the medians of median algorithm. 
Any help would be great. Thanks!