diff options
Diffstat (limited to 'eg/mapred_02.pl')
-rw-r--r-- | eg/mapred_02.pl | 27 |
1 files changed, 27 insertions, 0 deletions
diff --git a/eg/mapred_02.pl b/eg/mapred_02.pl new file mode 100644 index 0000000..31ab0eb --- /dev/null +++ b/eg/mapred_02.pl @@ -0,0 +1,27 @@ +#!/usr/bin/env perl +use strict; +use warnings; +use 5.010; + +use YAML; +use Net::Riak; + +my $riak = Net::Riak->new(); +my $result; + +$result = $riak->add('goog')->map(days_where_close_is_lower_than_open())->run; +say "days where close is lower than open"; +map { say $_ } sort {$a cmp $b} @$result; + +sub days_where_close_is_lower_than_open { + " +function(value, keyData, arg) { + var data = Riak.mapValuesJson(value)[0]; + if(data.Close < data.Open) + return [value.key]; + else + return []; +} +"; +} + |