diff options
author | franck cuny <franck@lumberjaph.net> | 2010-06-14 15:25:35 +0200 |
---|---|---|
committer | franck cuny <franck@lumberjaph.net> | 2010-06-14 15:25:35 +0200 |
commit | 06094dd3e7cc2d4b9299886037fc39f4344a2b9f (patch) | |
tree | e50f472413add487039e967783e560902bbcefc6 /lib/Net/Riak/Role | |
parent | tests for client (diff) | |
download | net-riak-06094dd3e7cc2d4b9299886037fc39f4344a2b9f.tar.gz |
add n::r::client and now client is a n::r::client
Diffstat (limited to 'lib/Net/Riak/Role')
-rw-r--r-- | lib/Net/Riak/Role/MapReduce.pm | 34 |
1 files changed, 34 insertions, 0 deletions
diff --git a/lib/Net/Riak/Role/MapReduce.pm b/lib/Net/Riak/Role/MapReduce.pm new file mode 100644 index 0000000..d80e242 --- /dev/null +++ b/lib/Net/Riak/Role/MapReduce.pm @@ -0,0 +1,34 @@ +package Net::Riak::Role::MapReduce; + +use Moose::Role; +use Net::Riak::MapReduce; + +sub add { + my ($self, @args) = @_; + my $mr = Net::Riak::MapReduce->new(client => $self->client); + $mr->add(@args); + $mr; +} + +sub link { + my ($self, @args) = @_; + my $mr = Net::Riak::MapReduce->new(client => $self->client); + $mr->link(@args); + $mr; +} + +sub map { + my ($self, @args) = @_; + my $mr = Net::Riak::MapReduce->new(client => $self->client); + $mr->mapd(@args); + $mr; +} + +sub reduce { + my ($self, @args) = @_; + my $mr = Net::Riak::MapReduce->new(client => $self->client); + $mr->reduce(@args); + $mr; +} + +1; |