lib/job.rb in trafficbroker-mandy-0.1.7 vs lib/job.rb in trafficbroker-mandy-0.1.8

@@ -32,9 +32,18 @@
     
     def reduce_tasks(count)
       set('mapred.reduce.tasks', count)
     end
     
+    def store(type, name, options={})
+      Mandy.stores[name] = case type
+      when :hbase
+        Stores::HBase.new(options)
+      else
+        raise "Unknown store type #{type}"
+      end
+    end
+    
     def map(klass=nil, &blk)
       @mapper_class = klass || Mandy::Mappers::Base.compile(&blk)
     end
     
     def reduce(klass=nil, &blk)
\ No newline at end of file