Class: HadoopDsl::ReducerFactory
Constant Summary
collapse
- @@reducer_class =
nil
Class Method Summary
collapse
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)
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
|