Class: HadoopDsl::ReducerFactory

Inherits:
MapRedFactory show all
Defined in:
lib/mapred_factory.rb

Constant Summary collapse

@@reducer_class = 
nil

Class Method Summary collapse

Methods inherited from MapRedFactory

dsl_name, require_dsl_lib

Class Method Details

.create(script, key, values) ⇒ Object 



34
35
36
37
38
39
40
41
42
43
 
# File 'lib/mapred_factory.rb', line 34

def self.create(script, key, values)
  # once decide in reduce loop
  unless @@reducer_class
    dsl_name = self.dsl_name(script)
    require_dsl_lib(dsl_name)
    @@reducer_class = eval("HadoopDsl::#{dsl_name}::#{dsl_name}Reducer")
  end

  @@reducer_class.new(script, key, values)
end