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;