Class: Mongo::Operation::MapReduce::Result

Inherits:
Result
  • Object
show all
Defined in:
lib/mongo/operation/map_reduce/result.rb

Overview

Defines custom behavior of results for a map reduce operation.

Since:

  • 2.0.0

Constant Summary collapse

COUNTS =

This constant is part of a private API. You should avoid using this constant if possible, as it may be removed or be changed in the future.

The counts field for the map/reduce.

Since:

  • 2.0.0

'counts'
RESULTS =

This constant is part of a private API. You should avoid using this constant if possible, as it may be removed or be changed in the future.

The field name for a result without a cursor.

Since:

  • 2.0.0

'results'
TIME =

This constant is part of a private API. You should avoid using this constant if possible, as it may be removed or be changed in the future.

The time the operation took constant.

Since:

  • 2.0.0

'timeMillis'

Constants inherited from Result

Result::CURSOR, Result::CURSOR_ID, Result::FIRST_BATCH, Result::N, Result::NAMESPACE, Result::NEXT_BATCH, Result::OK, Result::RESULT

Instance Attribute Summary

Attributes inherited from Result

#connection, #connection_description, #connection_global_id, #context, #replies

Instance Method Summary collapse

Methods inherited from Result

#acknowledged?, #cluster_time, #each, #error, #has_cursor_id?, #initialize, #inspect, #labels, #namespace, #ok?, #operation_time, #reply, #snapshot_timestamp, #topology_version, #write_concern_error?, #written_count

Constructor Details

This class inherits a constructor from Mongo::Operation::Result

Instance Method Details

#counts ⇒ Hash

Gets the map/reduce counts from the reply.

Examples:

Get the counts.

result.counts

Returns:

  • (Hash) —

    A hash of the result counts.

Since:

  • 2.0.0



52
53
54
 
# File 'lib/mongo/operation/map_reduce/result.rb', line 52

def counts
  reply.documents[0][COUNTS]
end

#cursor_id ⇒ Integer

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

Get the cursor id.

Examples:

Get the cursor id.

result.cursor_id

Returns:

  • (Integer) —

    Always 0 because map reduce doesn’t return a cursor.

Since:

  • 2.5.0



127
128
129
 
# File 'lib/mongo/operation/map_reduce/result.rb', line 127

def cursor_id
  0
end

#documents ⇒ Array<BSON::Document>

Get the documents from the map/reduce.

Examples:

Get the documents.

result.documents

Returns:

  • (Array<BSON::Document>) —

    The documents.

Since:

  • 2.0.0



65
66
67
 
# File 'lib/mongo/operation/map_reduce/result.rb', line 65

def documents
  reply.documents[0][RESULTS] || reply.documents[0][RESULT]
end

#returned_count ⇒ Integer

Get the number of documents returned by the server in this batch.

Map/Reduce operation returns documents inline without using cursors; as such, the standard Mongo::Reply#returned_count does not work correctly for Map/Reduce.

Note that the Map/Reduce operation is limited to max BSON document size (16 MB) in its inline result set.

Returns:

  • (Integer) —

    The number of documents returned.

Since:

  • 2.0.0



143
144
145
 
# File 'lib/mongo/operation/map_reduce/result.rb', line 143

def returned_count
  reply.documents.length
end

#successful? ⇒ true, false

Note:

If the write was unacknowledged, then this will always return true.

If the result was a command then determine if it was considered a success.

Examples:

Was the command successful?

result.successful?

Returns:

  • (true, false) —

    If the command was successful.

Since:

  • 2.0.0



82
83
84
 
# File 'lib/mongo/operation/map_reduce/result.rb', line 82

def successful?
  !documents.nil?
end

#time ⇒ Integer

Get the execution time of the map/reduce.

Examples:

Get the execution time.

result.time

Returns:

  • (Integer) —

    The executing time in milliseconds.

Since:

  • 2.0.0



95
96
97
 
# File 'lib/mongo/operation/map_reduce/result.rb', line 95

def time
  reply.documents[0][TIME]
end

#validate! ⇒ Result

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

Note:

This only checks for errors with writes since authentication is handled at the connection level and any authentication errors would be raised there, before a Result is ever created.

Validate the result by checking for any errors.

Examples:

Validate the result.

result.validate!

Returns:

  • (Result) —

    The result if verification passed.

Raises:

Since:

  • 2.0.0



114
115
116
 
# File 'lib/mongo/operation/map_reduce/result.rb', line 114

def validate!
  documents.nil? ? raise_operation_failure : self
end