From a3e5554ff13b923b67768980e69bd43ae34914a9 Mon Sep 17 00:00:00 2001
From: gmaurice <gmaurice@gm.livebox.home>
Date: Tue, 5 Oct 2010 15:34:49 +0200
Subject: add support of array arguments in Net::Riak::MapReduce->add()

---
 lib/Net/Riak/MapReduce.pm | 21 +++++++++++++++++++--
 1 file changed, 19 insertions(+), 2 deletions(-)

(limited to 'lib/Net/Riak/MapReduce.pm')

diff --git a/lib/Net/Riak/MapReduce.pm b/lib/Net/Riak/MapReduce.pm
index 499335a..70ed214 100644
--- a/lib/Net/Riak/MapReduce.pm
+++ b/lib/Net/Riak/MapReduce.pm
@@ -48,10 +48,17 @@ sub add {
     my $self = shift;
     my $arg  = shift;
 
+    if (ref $arg eq 'ARRAY') {
+        do{
+            $self->add_input($arg);
+        }while(my $arg = shift @_);
+        return $self;
+    }
+    
     if (!scalar @_) {
         if (blessed($arg)) {
             $self->add_object($arg);
-          } else {
+        } else {
             $self->add_bucket($arg);
         }
     }
@@ -225,12 +232,22 @@ The RiakMapReduce object allows you to build up and run a map/reduce operation o
 
 =item add
 
-arguments: bucketname
+arguments: bucketname or arrays or Riak::Object
 
 return: a Net::Riak::MapReduce object
 
 Add inputs to a map/reduce operation. This method takes three different forms, depending on the provided inputs. You can specify either a RiakObject, a string bucket name, or a bucket, key, and additional arg.
 
+Create a MapReduce job
+
+    my $mapred = $riak->add( ["alice","p1"],["alice","p2"],["alice","p5"] );
+    
+Add your inputs to a MapReduce job
+
+    $mapred->add( ["alice","p1"],["alice","p2"] );
+    $mapred->add( "alice", "p5" );
+    $mapred->add( $riak->bucket("alice")->get("p6") );
+
 =item add_object
 
 =item add_bucket_key_data
-- 
cgit 1.4.1