From 859212604e96818f5ec0b45c01d83bf2934c6697 Mon Sep 17 00:00:00 2001
From: franck cuny <franck@lumberjaph.net>
Date: Wed, 16 Jun 2010 11:49:34 +0200
Subject: add three map/reduce operations (from the fast track)

---
 eg/mapred_01.pl | 26 ++++++++++++++++++++++++++
 1 file changed, 26 insertions(+)
 create mode 100644 eg/mapred_01.pl

(limited to 'eg/mapred_01.pl')

diff --git a/eg/mapred_01.pl b/eg/mapred_01.pl
new file mode 100644
index 0000000..76e26b2
--- /dev/null
+++ b/eg/mapred_01.pl
@@ -0,0 +1,26 @@
+#!/usr/bin/env perl
+use strict;
+use warnings;
+use 5.010;
+
+use Net::Riak;
+
+my $riak = Net::Riak->new();
+my $result;
+
+$result = $riak->add('goog')->map(get_day_where_high_is('600.00'))->run;
+say "days where high is over 600:";
+map { say $_ } sort {$a cmp $b } @$result;
+
+sub get_day_where_high_is {
+    my $val = shift;
+"
+function(value, keyData, arg) {
+  var data = Riak.mapValuesJson(value)[0];
+  if(data.High && data.High > $val)
+    return [value.key];
+  else
+    return [];
+}
+";
+}
-- 
cgit v1.2.3