lib/rbhive/connection.rb in rbhive-0.1.11 vs lib/rbhive/connection.rb in rbhive-0.1.12

@@ -53,9 +53,13 @@
     
     def priority=(priority)
       set("mapred.job.priority", priority)
     end
     
+    def queue=(queue)
+      set("mapred.job.queue.name", queue)
+    end
+    
     def set(name,value)
       @logger.info("Setting #{name}=#{value}")
       client.execute("SET #{name}=#{value}")
     end