Class: HadoopDsl::MapperFactory

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

Constant Summary collapse

@@mapper_class =

for cache in map loop

nil

Class Method Summary collapse

Methods inherited from MapRedFactory

dsl_name, require_dsl_lib

Class Method Details

.create(script, key, value) ⇒ Object 



20
21
22
23
24
25
26
27
28
29
 
# File 'lib/mapred_factory.rb', line 20

def self.create(script, key, value)
  # once decide in map loop
  unless @@mapper_class
    dsl_name = self.dsl_name(script)
    require_dsl_lib(dsl_name)
    @@mapper_class = eval("HadoopDsl::#{dsl_name}::#{dsl_name}Mapper")
  end

  @@mapper_class.new(script, key, value)
end