类:Mongo::Operation::MapReduce::Result
- 继承:
-
操作::结果
- 对象
- 操作::结果
- Mongo::Operation::MapReduce::Result
- 定义于:
- lib/ Mongo/operation/map_reduce/result.rb
Overview
定义 Map Reduce 操作结果的自定义行为。
常量摘要折叠
- COUNTS =
此常量是私有 API 的一部分。 应尽可能避免使用此常量,因为它将来可能会被删除或更改。
map/reduce 的计数字段。
'counts'- 结果 =
此常量是私有 API 的一部分。 应尽可能避免使用此常量,因为它将来可能会被删除或更改。
不带游标的结果的字段名称。
'结果'- TIME =
此常量是私有 API 的一部分。 应尽可能避免使用此常量,因为它将来可能会被删除或更改。
操作花费的时间恒定。
'timeMillis'
实例方法摘要折叠
-
# counts ⇒ 哈希
从回复中获取 map/reduce 计数。
-
# cursor_id = "Integer"
private
获取游标 ID。
-
# 个documents ⇒ Array<BSON::Document>
从 map/reduce 中获取文档。
-
# returned_count ⇒ 整数
获取此批处理中服务器返回的文档数。
-
# 成功? ⇒ true, false
如果结果是命令,则确定是否成功。
-
# time ⇒ 整数
获取 map/reduce 的执行时间。
-
#validate! ⇒ Result
private
通过检查是否存在任何错误来验证结果。
实例方法详细信息
# counts ⇒哈希
从回复中获取 map/reduce 计数。
52 53 54 |
# File 'lib/ Mongo/operation/map_reduce/result.rb', line 52 def counts 回复.文档[0][COUNTS] end |
# cursor_id = " Integer "
此方法是私有 API 的一部分。 您应尽可能避免使用此方法,因为它将来可能会被删除或更改。
获取游标 ID。
127 128 129 |
# File 'lib/ Mongo/operation/map_reduce/result.rb', line 127 def cursor_id 0 end |
# 个documents ⇒ Array<BSON::Document>
从 map/reduce 中获取文档。
65 66 67 |
# File 'lib/ Mongo/operation/map_reduce/result.rb', line 65 def 文档 回复.文档[0][结果] || 回复.文档[0][结果] end |
# returned_count ⇒整数
获取此批处理中服务器返回的文档数。
Map/Reduce 操作以内联方式返回文档,无需使用游标;因此,标准 Mongo::Reply#returned_count 无法正常用于 Map/Reduce。
请注意,Map/Reduce 操作在内联结果集中受到最大 BSON 文档大小 ( 16 MB) 的限制。
143 144 145 |
# File 'lib/ Mongo/operation/map_reduce/result.rb', line 143 def returned_count 回复.文档.长度 end |
#成功? ⇒ true , false
如果写入未被确认,则始终返回 true。
如果结果是命令,则确定是否成功。
82 83 84 |
# File 'lib/ Mongo/operation/map_reduce/result.rb', line 82 def 成功? !文档.nil? end |
# time ⇒整数
获取 map/reduce 的执行时间。
95 96 97 |
# File 'lib/ Mongo/operation/map_reduce/result.rb', line 95 def 时间 回复.文档[0][时间] end |
# validate! ⇒结果
此方法是私有 API 的一部分。 您应尽可能避免使用此方法,因为它将来可能会被删除或更改。
这只检查写入错误,因为身份验证是在连接级别处理的,并且在创建结果之前,任何身份验证错误都会在那里引发。
通过检查是否存在任何错误来验证结果。
114 115 116 |
# File 'lib/ Mongo/operation/map_reduce/result.rb', line 114 def validate! 文档.nil? ? Raise_operation_failure : self end |