Class: HadoopDsl::WordCount::WordCountReducer

Inherits:
BaseReducer show all
Defined in:
lib/word_count.rb

Instance Attribute Summary

Attributes inherited from BaseMapRed

#emitted

Instance Method Summary collapse

Methods inherited from BaseReducer

#aggregate, #identity

Methods inherited from BaseMapRed

#emit

Methods included from DslController

#pre_process, #run

Methods included from DslElement

#method_missing

Constructor Details

#initialize(script, key, values) ⇒ WordCountReducer

Returns a new instance of WordCountReducer.



37
38
39
 
# File 'lib/word_count.rb', line 37

def initialize(script, key, values)
  super(script, WordCountReducerModel.new(key, values))
end

Dynamic Method Handling

This class handles dynamic methods through the method_missing method in the class HadoopDsl::DslElement

Instance Method Details

#count_uniq ⇒ Object

emitters



45
 
# File 'lib/word_count.rb', line 45

def count_uniq; aggregate unless @model.total_value? end

#total(*types) ⇒ Object 



46
 
# File 'lib/word_count.rb', line 46

def total(*types); aggregate if @model.total_value? end