Changeset [daf6770985660348f625cb733e5fd9f53185f6f8] by Shayan Pooya
May 28th, 2014 @ 07:32 AM
worker_input: implement the add_inputs function.
In the current implementation, the inputs received by
worker_input may contain
duplicates and have to be taken care of. Moreover, the sequence
numbers given
to the inputs are important. Disco should give brand new sequence
numbers to
the new inputs.
https://github.com/discoproject/disco/commit/daf6770985660348f625cb...
Committed by Shayan Pooya
- M master/src/worker_inputs.erl
Create new ticket
Create your profile
Help contribute to this project by taking a few moments to create your personal profile. Create your profile ยป
Disco is an open-source implementation of the Map-Reduce framework for distributed computing. As the original framework, Disco supports parallel computations over large data sets on unreliable cluster of computers.