Class: Riak::MapReduce::Phase

Inherits:

Object

• Object
• Riak::MapReduce::Phase

show all

Includes:

Util::Translation

Defined in:

lib/riak/map_reduce/phase.rb

Overview

Instance Attribute Summary (collapse)

• - (Array) arg

  Any extra static arguments to pass to the phase.

• - (String, ...) function

  For :map and :reduce types, the Javascript function to run (as a string or hash with bucket/key), or the module + function in Erlang to run.

• - (Boolean) keep

  Whether results of this phase will be returned.

• - (String) language

  The language of the phase's function - “javascript” or “erlang”.

• - (Symbol) type

  The type of phase - :map, :reduce, or :link.

Instance Method Summary (collapse)

• - (Hash) as_json(options = nil)

  Converts the phase to its JSON-compatible representation for job invocation.

• - (Phase) initialize(options = {}) constructor

  Creates a phase in the map-reduce pipeline.

• - (String) to_json(*a)

  Converts the phase to JSON for use while invoking a job.

Methods included from Util::Translation

#i18n_scope, #t

34
35
36
37
38
39
40

# File 'lib/riak/map_reduce/phase.rb', line 34

def initialize(options={})
  self.type = options[:type]
  self.language = options[:language] || "javascript"
  self.function = options[:function]
  self.keep = options[:keep] || false
  self.arg = options[:arg]
end

25
26
27

# File 'lib/riak/map_reduce/phase.rb', line 25

def arg
  @arg
end

16
17
18

# File 'lib/riak/map_reduce/phase.rb', line 16

def function
  @function
end

22
23
24

# File 'lib/riak/map_reduce/phase.rb', line 22

def keep
  @keep
end

19
20
21

# File 'lib/riak/map_reduce/phase.rb', line 19

def language
  @language
end

13
14
15

# File 'lib/riak/map_reduce/phase.rb', line 13

def type
  @type
end

73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95

# File 'lib/riak/map_reduce/phase.rb', line 73

def as_json(options=nil)
  obj = case type
        when :map, :reduce
          defaults = {"language" => language, "keep" => keep}
          case function
          when Hash
            defaults.merge(function)
          when String
            if function =~ /\s*function/
              defaults.merge("source" => function)
            else
              defaults.merge("name" => function)
            end
          when Array
            defaults.merge("module" => function[0], "function" => function[1])
          end
        when :link
          spec = WalkSpec.normalize(function).first
          {"bucket" => spec.bucket, "tag" => spec.tag, "keep" => spec.keep || keep}
        end
  obj["arg"] = arg if arg
  { type => obj }
end

67
68
69

# File 'lib/riak/map_reduce/phase.rb', line 67

def to_json(*a)
  as_json.to_json(*a)
end