issues
search
coderplay
/
dragon
Real-time computing system based on hadoop yarn
12
stars
5
forks
source link
Merge code from Min zhou, includes #73 #82 #80 #79
#85
Closed
coderplay
closed
11 years ago
coderplay
commented
11 years ago
Remove the package of dag
73 Add Mapper, Reducer and Partitioner
Redesign EventProducer and EventEmitter
Move the register method from AbstractWatchService to WatchService
Remove the temporary Mapper and Reducer introduced by Jiannan
WatchService should start watch quickly
82 Add child executor, which can execute map or reduce childs
Let user can defined the mapper class and reducer class of a dragon job
Delete SequenceFileEventProduer, because the inferfaces of EventProducer has changed
73 Add Mapper, Reducer and Partitioner
82 Add child executor, which can execute map or reduce childs