Method: MapRedus::Counter.reduce_perform
- Defined in:
- lib/mapredus/default_classes.rb
.reduce_perform(process, key) ⇒ Object
63 64 65 |
# File 'lib/mapredus/default_classes.rb', line 63 def self.reduce_perform(process, key) process.emit(key, FileSystem.llen(process.map_key(key))) end |