Class: MongoMapperParallel::Key

Inherits:
Object
  • Object
show all
Defined in:
lib/mongo_mapper_parallel.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(opts = {}) ⇒ Key

A chunk that will be parallelized

Parameters:

  • opts (Hash) (defaults to: {}) —

    the options to create the chunk.

Options Hash (opts):

  • :key (String) —

    the lower bound of the range of resources to retrieve

  • :future_key (String) —

    the upper bound for the range of resources to retrieve

  • :compiler (MongoMapperParallel) —

    the Parallel execution object that holds the keys, javascript, and arguments.

  • :debug (Boolean) —

    whether to show messages during the process.



38
39
40
41
42
43
44
45
 
# File 'lib/mongo_mapper_parallel.rb', line 38

def initialize(opts={})
	@key        = opts[:key]
	@compiler   = opts[:compiler]
	@position   = opts[:position]
	@future_key = opts[:future_key]
	@completed  = false
	@debug      = opts[:debug].nil? ? true : opts[:debug]
end

Instance Attribute Details

#compiler ⇒ Object (readonly)

Returns the value of attribute compiler.



28
29
30
 
# File 'lib/mongo_mapper_parallel.rb', line 28

def compiler
  @compiler
end

#completed ⇒ Object

Returns the value of attribute completed.



27
28
29
 
# File 'lib/mongo_mapper_parallel.rb', line 27

def completed
  @completed
end

#debug ⇒ Object

Returns the value of attribute debug.



29
30
31
 
# File 'lib/mongo_mapper_parallel.rb', line 29

def debug
  @debug
end

#future_key ⇒ Object

A chunk that will be parallelized



25
26
27
 
# File 'lib/mongo_mapper_parallel.rb', line 25

def future_key
  @future_key
end

#key ⇒ Object

Returns the value of attribute key.



26
27
28
 
# File 'lib/mongo_mapper_parallel.rb', line 26

def key
  @key
end

Instance Method Details

#args ⇒ Array, Hash

The arguments to pass to the Javascript function to run on the resources

Returns:

  • (Array, Hash) —

    The arguments to pass to the javascript function



56
 
# File 'lib/mongo_mapper_parallel.rb', line 56

def args;          @compiler.args;          end

#command_class ⇒ Class

The Ruby Class representing the collection containing the resources

Returns:

  • (Class) 


61
 
# File 'lib/mongo_mapper_parallel.rb', line 61

def command_class; @compiler.command_class; end

#compile ⇒ Object

Sends the Javascript function, the range, and the arguments to the MongoDB instance for computation via the ‘db.runCommand` command.



65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
 
# File 'lib/mongo_mapper_parallel.rb', line 65

def compile
	search_opts = {:name => {:$gte => @key}}
	if @future_key then search_opts[:name][:$lte] = @future_key	end
	begin
		command_class.database.command({
			:"$eval" => javascript,
			:args    => [@key, @future_key, args],
			:nolock => true
			})
	rescue Mongo::ConnectionFailure
		raise Mongo::ConnectionFailure.new "Connection disconnected at position #{@position}"
	end
	@completed = true
	puts "Completed chunk (#{@position})".green if @debug
end

#javascript ⇒ String

The javascript function to run on the resources

Returns:

  • (String) —

    The function to run.



50
 
# File 'lib/mongo_mapper_parallel.rb', line 50

def javascript;    @compiler.javascript;    end