diff options
Diffstat (limited to '')
| -rw-r--r-- | lib/Net/Riak/MapReduce.pm | 21 |
1 files changed, 19 insertions, 2 deletions
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 |