blob: 992644d8f612e25c30e60592f3ea27dd785e7245 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
|
package Net::Riak::MapReducePhase;
use Moose;
use Scalar::Util;
use JSON;
has type => (is => 'rw', isa => 'Str', required => 1,);
has function => (is => 'ro', isa => 'Str', required => 1);
has arg => (is => 'ro', isa => 'ArrayRef', default => 'None');
has language => (is => 'ro', isa => 'Str', default => 'javascript');
has keep => (is => 'rw', isa => 'JSON::Boolean', default => sub {JSON::false});
sub to_array {
my $self = shift;
my $step_def = {
keep => $self->keep,
language => $self->language,
arg => $self->arg
};
if ($self->function =~ m!\{!) {
$step_def->{source} = $self->function;
}else{
$step_def->{name} = $self->function;
}
return {$self->type => $step_def};
}
1;
|