diff options
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; |