Contents

class MapReduce<%= name.capitalize %>
  include SkynetDebugger

  def self.run
    job = Skynet::Job.new(
      :mappers => 2, #change to whatever is a good number
      :reducers => 1, #same
      :map_reduce_class => self,
      :map_data => [] #acquire your data!
    )
    job.run
  end

  def self.map(profiles)
    #map code
  end

  def self.reduce(pairs)
    #reduce code
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
gigantron-0.1.0	gigantron_generators/mapreduce_task/templates/mapreduce/mr_task.rb