diff options
Diffstat (limited to 'eg/mapred_01.pl')
-rw-r--r-- | eg/mapred_01.pl | 26 |
1 files changed, 26 insertions, 0 deletions
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 []; +} +"; +} |