クラス: Mongo::Collection::View::MapReduce
- 継承:
-
オブジェクト
- オブジェクト
- Mongo::Collection::View::MapReduce
- 次による拡張機能。
- 転送可能
- 定義:
- build/ruby-Driver-v 2.19 /lib/mongo/collection/view/map_reduce.rb
Overview
コレクション ビューの map/reduce 操作に関する動作を提供します。
定数の概要の削減
- INLIN =
インライン オプション。
'inline'.freeze
- REDIRECT =
非推奨。
メッセージをリルートします。
' MapReduce操作をプライマリ サーバーにリルーティングします。 '.freeze
Loggableに含まれる定数
インスタンス属性の概要を折りたたむ
-
# map_function = string
readOnly
Map マップ 関数。
-
# reduce_function = string
readOnly
reduce 関数を使用します。
-
#view ⇒ View
readOnly
コレクション ビューを表示します。
不変に含まれる属性
インスタンス メソッドの概要を折りたたむ
-
各{|Each| ... } = 列挙型
map/reduce によって返されたドキュメントを反復処理します。
-
# execution = Mongo::Operation::Result
コレクションに出力される場合、結果を検索するために取得クエリを実行せずに、map reduce を実行します。
-
# finalize (function = nil) = mapReduce, string
操作の finalize 関数を設定または取得します。
-
#初期化(表示、マッピング、削減、オプション = {}) = MapReduce
コンストラクター
指定されたコレクション ビュー、関数、オプションの map/reduce を初期化します。
-
# js_mode (値 = nil) = MapReduce, ...
操作用の jsMode フラグを設定または取得します。
-
#out (ロケーション= nil)= MapReduce、ハッシュ
操作の出力場所を設定または取得します。
-
#out_collection_name ⇒ Object
map-reduce の結果が書き込まれるコレクション名を返します。
-
#out_database_name =オブジェクト
map-reduce の結果が書き込まれるデータベース名を返します。
-
#スコープ(オブジェクト = nil)= MapReduce、ハッシュ
操作のスコープを設定または取得します。
-
#冗長(値 = nil) = MapReduce、ハッシュ
結果にタイミング情報を含めるかどうか。
再試行可能な に含まれるメソッド
#read_worker 、 #select_server 、 #write_worker
Loggableに含まれるメソッド
#log_debug, #log_error, #log_fatal, #log_info, #log_warn, #logger
コンストラクターの詳細
#初期化(表示、マッピング、削減、オプション = {}) = MapReduce
指定されたコレクション ビュー、関数、オプションの map/reduce を初期化します。
113 114 115 116 117 118 119 120 |
ファイル 'Build/ruby-Driver-v 2.19 /lib/mongo/collection/view/map_reduce.rb', 行113 デフォルト 初期化(表示, map, reduce, = {}) @view = 表示 @map_function = map.dup.freeze @reduce_function = reduce.dup.freeze @options = BSON::ドキュメント.新着情報().freeze クライアント.log_警告(' map_reduce 操作は非推奨です。代わりに集計パイプラインを使用してください') end |
インスタンス属性の詳細
#map_function = string (読み取り専用)
map 関数を返します。
48 49 50 |
ファイル 'Build/ruby-Driver-v 2.19 /lib/mongo/collection/view/map_reduce.rb', 行48 デフォルト map_function @map_function end |
#reduce_function = string (読み取り専用)
reduce 関数の reduce を返します。
51 52 53 |
ファイル 'Build/ruby-Driver-v 2.19 /lib/mongo/collection/view/map_reduce.rb', 行51 デフォルト reduce_function @reduce_function end |
#表示=表示(readonly)
コレクション ビューのビューを返します。
45 46 47 |
ファイル 'Build/ruby-Driver-v 2.19 /lib/mongo/collection/view/map_reduce.rb', 行45 デフォルト 表示 @view end |
インスタンス メソッドの詳細
各{|Each| ... } =列挙型
map/reduce によって返されたドキュメントを反復処理します。
71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 |
ファイル 'Build/ruby-Driver-v 2.19 /lib/mongo/collection/view/map_reduce.rb', 行71 デフォルト 各 @cursor = nil セッション = クライアント.送信(:get_session, @options) サーバー = クラスター.next_primary(nil, セッション) 結果 = send_initial_query(サーバー, セッション, context: 操作::Context.新着情報(クライアント: クライアント, セッション: セッション)) 結果 = send_fetch_query(サーバー, セッション) ただし、 インライン @cursor = Cursor.新着情報(表示, 結果, サーバー, セッション: セッション) 場合 ブロック_指定 @cursor.各 行う |doc| ノードの数 doc end else @cursor.to_enum end end |
# execution = Mongo::Operation::Result
結果を検索するための取得クエリを実行せずに、map reduce を実行
if outputted to a collection.
223 224 225 226 227 228 229 230 231 |
ファイル 'Build/ruby-Driver-v 2.19 /lib/mongo/collection/view/map_reduce.rb', 行223 デフォルト 実行する 表示.送信(:with_session, @options) 行う |セッション| write_concern = 表示.write_concern_with_session(セッション) context = 操作::Context.新着情報(クライアント: クライアント, セッション: セッション) nro_write_with_retry(write_concern, context: context) 行う |接続, txn_num, context| send_initial_query_with_ connection(接続, セッション, context: context) end end end |
# finalize (function =nil) = mapReduce , string
操作の finalize 関数を設定または取得します。
98 99 100 |
ファイル 'Build/ruby-Driver-v 2.19 /lib/mongo/collection/view/map_reduce.rb', 行98 デフォルト finalize(関数 = nil) 構成する(: finalize, 関数) end |
# js_mode (値 = nil) = MapReduce 、...
操作用の jsMode フラグを設定または取得します。
133 134 135 |
ファイル 'Build/ruby-Driver-v 2.19 /lib/mongo/collection/view/map_reduce.rb', 行133 デフォルト js_mode(価値 = nil) 構成する(:js_mode, 価値) end |
#out (ロケーション= nil)= MapReduce 、ハッシュ
操作の出力場所を設定または取得します。
157 158 159 |
ファイル 'Build/ruby-Driver-v 2.19 /lib/mongo/collection/view/map_reduce.rb', 行157 デフォルト out(ロケーション = nil) 構成する(:out, ロケーション) end |
#out_collection_name ⇒ Object
map-reduce の結果が書き込まれるコレクション名を返します。 結果がインラインで返される場合、 は nil を返します。
163 164 165 166 167 168 169 |
ファイル 'Build/ruby-Driver-v 2.19 /lib/mongo/collection/view/map_reduce.rb', 行163 デフォルト out_collection_name 場合 [:out].respond_to?(:keys) [:out][OUT_ACTIONS.find 行う |アクション| [:out][アクション] end] end || [:out] end |
#out_database_name =オブジェクト
map-reduce の結果が書き込まれるデータベース名を返します。 結果がインラインで返される場合、 は nil を返します。
173 174 175 176 177 178 179 180 181 |
ファイル 'Build/ruby-Driver-v 2.19 /lib/mongo/collection/view/map_reduce.rb', 行173 デフォルト out_database_name 場合 [:out] 場合 [:out].respond_to?(:keys) & & (db = [:out][:db]) db else database.name end end end |
#スコープ(オブジェクト = nil)= MapReduce 、ハッシュ
操作のスコープを設定または取得します。
194 195 196 |
ファイル 'Build/ruby-Driver-v 2.19 /lib/mongo/collection/view/map_reduce.rb', 行194 デフォルト scope(オブジェクト = nil) 構成する(:scope, オブジェクト) end |
#冗長(値 = nil) = MapReduce 、ハッシュ
結果にタイミング情報を含めるかどうか。
210 211 212 |
ファイル 'Build/ruby-Driver-v 2.19 /lib/mongo/collection/view/map_reduce.rb', 行210 デフォルト verbose(価値 = nil) 構成する(:verbose, 価値) end |