Clase: Mongo::Collection::View::MapReduce

Hereda:
Objeto
  • Objeto
Mostrar todo
Ampliado por:
Reenviable
Incluye:
Enumerables, Inmutables, Registrables, Reintestables
Definido en:
lib/mongo/collection/view/map_reduce.rb

Overview

Proporciona un comportamiento en torno a una operación Map/Reduce en la vista de la colección.

Desde:

  • 2.0.0

Colapso delresumen constante

EN LÍNEA =

La opción en línea.

Desde:

  • 2.1.0

'inline'.freeze
REDIRECCIONAMIENTO =
Obsoleto.

Redirigir mensaje.

Desde:

  • 2.1.0

'Redirigiendo la operación de MapReduce al servidor principal.'.freeze

Constantes incluidas desde Loggable

Registrable::PREFIX

Resumen de atributos de la instancia colapsar

Atributos incluidos de Inmutable

#options

Resumen del método de instancia colapsar

Métodos incluidos en Retryable

#read_worker, #select_server, #write_worker

Métodos incluidos desde Registrable

#log_debug, #log_error, #log_fatal, #log_info, #log_warn, #logger

Detalles del constructor

#initialize(vista, mapa, reducir, opciones = {}) ⇒ MapReduce

Inicializa el map/reduce para la vista de colección, funciones y opciones proporcionadas.

Ejemplos:

Crear la nueva vista de mapa/reducción.

Parámetros:

  • vista (Collection::View) —

    La vista de la colección.

  • map (string) —

    La función de mapa.

  • disminuir (string) —

    La función de reducción.

  • opciones (Hash) (por defecto: {}) —

    Las opciones de map/reduce.

Desde:

  • 2.0.0



121
122
123
124
125
126
127
128
 
# Archivo 'lib/mongo/collection/view/map_reduce.rb', línea 121

def inicializar(vista, map, disminuir, opciones = {})
  @view = vista
  @map_function = map.dup.freeze
  @reduce_function = disminuir.dup.freeze
  @options = BSON::Documento.Nuevo(opciones).freeze

  Cliente.advertencia de registro('La operación map_reduce está obsoleta, usa la pipeline de agregación en su lugar')
end

Detalles de los atributos de instancia

#map_function ⇒ Cadena (solo lectura)

Retorna el mapa La función map.

Devuelve:

  • (string) —

    La función de mapa.

Desde:

  • 2.0.0



48
49
50
 
# Archivo 'lib/mongo/collection/view/map_reduce.rb', línea 48

def función_mapa
  @map_function
end

#reduce_function ⇒ String (solo lectura)

Devuelve reduce La función reduce.

Devuelve:

  • (string) —

    reduce La función reduce.

Desde:

  • 2.0.0



51
52
53
 
# Archivo 'lib/mongo/collection/view/map_reduce.rb', línea 51

def reduce_function
  @reduce_function
end

#vista ⇒ Vista (solo lectura)

Devuelve vista La vista de la colección.

Devuelve:

  • (Vista) -

    ver La vista de colección.

Desde:

  • 2.0.0



45
46
47
 
# Archivo 'lib/mongo/collection/view/map_reduce.rb', línea 45

def vista
  @view
end

Detalles del método de instancia

#each {|Each| ... } ⇒ Enumerator

Iterar a través de los documentos devueltos por el mapa/reducción.

Ejemplos:

Iterar a través del resultado del map/reduce.

map_reduce.each do |document|
  p document
end

Parámetros de rendimiento:

  • Cada uno (encriptada) —

    documento coincidente

Devuelve:

  • (Enumerator) —

    El enumerador.

Desde:

  • 2.0.0



71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
 
# Archivo 'lib/mongo/collection/view/map_reduce.rb', línea 71

def cada
  @cursor = nulo
  sesión = Cliente.get_session(@options)
  Server = clúster.siguiente_principal(nulo, sesión)
  context = Operación::Context.Nuevo(cliente: Cliente, sesión: sesión, operation_timeouts: vista.tiempos de espera de operación)
  si Server.load_balancer?
    # La conexión se verificará cuando se termine con el cursor.
    Conexión = Server.group.check_out(context: context)
    Resultado = send_initial_query_with_connection(Conexión, context.sesión, context: context)
    Resultado = send_fetch_query_with_connection(Conexión, sesión) a menos que ¿en línea?
  else
    Resultado = enviar_consulta_inicial(Server, context)
    Resultado = enviar_query_obtener(Server, sesión) a menos que ¿en línea?
  end
  @cursor = Cursor.Nuevo(vista, Resultado, Server, sesión: sesión)
  si ¿block_given?
    @cursor.cada hacer |doc|
      rendimiento doc
    end
  else
    @cursor.to_enum
  end
end

#ejecutar ⇒ Mongo::Operación::Resultado

Ejecute el map reduce, sin realizar una query fetch para recuperar los resultados

if outputted to a collection.

Ejemplos:

Ejecute el mapa reduce y obtenga el resultado sin procesar.

map_reduce.execute

Devuelve:

Desde:

  • 2.5.0



231
232
233
234
235
236
237
238
239
 
# Archivo 'lib/mongo/collection/view/map_reduce.rb', línea 231

def ejecutar
  vista.enviar(:con_sesión, @options) hacer |sesión|
    escribir_preocupación = vista.escribir_preocupación_con_la_sesión(sesión)
    context = Operación::Context.Nuevo(cliente: Cliente, sesión: sesión)
    nro_write_with_retry(escribir_preocupación, context: context) hacer |Conexión, txn_num, context|
      send_initial_query_with_connection(Conexión, sesión, context: context)
    end
  end
end

#finalizar(función = nil) ⇒ MapReduce, String

Establece u obtiene la función de finalización para la operación.

Ejemplos:

Configura la función Finalizar.

map_reduce.finalize(function)

Parámetros:

  • función (Cadena) (predeterminado: nulo) —

    La función finalize js.

Devuelve:

  • (MapReduce, string) —

    La nueva operación MapReduce o el valor de la función.

Desde:

  • 2.0.0



106
107
108
 
# Archivo 'lib/mongo/collection/view/map_reduce.rb', línea 106

def finaliza(función = nulo)
  configurar(:finalize, función)
end

#js_mode(value = nil) ⇒ MapReduce, ...

Establezca u obtenga la bandera jsMode para la operación.

Ejemplos:

Establecer el modo js para la operación.

map_reduce.js_mode(true)

Parámetros:

  • Valor (verdadero, falso) (predeterminado: nulo) —

    El valor jsMode.

Devuelve:

  • (MapReduce, verdadero, falso) —

    La nueva operación MapReduce o el valor del indicador jsMode.

Desde:

  • 2.0.0



141
142
143
 
# Archivo 'lib/mongo/collection/view/map_reduce.rb', línea 141

def js_mode(Valor = nulo)
  configurar(:js_mode, Valor)
end

#salida(ubicación = nula) ⇒ MapReduce, Hash

Establece u obtén la ubicación de salida para la operación.

Ejemplos:

Establezca la salida en línea.

map_reduce.out(inline: 1)

Establece la colección de salida para fusionar.

map_reduce.out(merge: 'users')

Establece la colección de salida para reemplazo.

map_reduce.out(replace: 'users')

Establezca la colección de salida para reducir.

map_reduce.out(reduce: 'users')

Parámetros:

  • ubicación (Hash) (predeterminado: nulo) —

    Los detalles de la ubicación de salida.

Devuelve:

  • (MapReduce,Hash) —

    La nueva operación MapReduce o el valor de la ubicación de salida.

Desde:

  • 2.0.0



165
166
167
 
# Archivo 'lib/mongo/collection/view/map_reduce.rb', línea 165

def cabo(ubicación = nulo)
  configurar(:afuera, ubicación)
end

#out_collection_name ⇒ Object

Devuelve el nombre de la colección donde se escribe el resultado de map-reduce. Si el resultado se devuelve inline, retorna nil.

Desde:

  • 2.0.0



171
172
173
174
175
176
177
 
# Archivo 'lib/mongo/collection/view/map_reduce.rb', línea 171

def out_collection_name
  si opciones[:afuera].respond_to?(:llaves)
    opciones[:afuera][ACCIONES_EXTERNAS.buscar hacer |acción|
      opciones[:afuera][acción]
    end]
  end || opciones[:afuera]
end

#nombre_de_base_de_datos_salida ⇒ Objeto

Devuelve el nombre de la base de datos donde se escriben los resultados de map-reduce. Si el resultado se devuelve inline, retorna nil.

Desde:

  • 2.0.0



181
182
183
184
185
186
187
188
189
 
# Archivo 'lib/mongo/collection/view/map_reduce.rb', línea 181

def out_database_name
  si opciones[:afuera]
    si opciones[:afuera].respond_to?(:llaves) && (db = opciones[:afuera][:db])
      db
    else
      database.Nombre
    end
  end
end

#ámbito(objeto = nil) ⇒ MapReduce, Hash

Establece u obtiene un alcance en la operación.

Ejemplos:

Establezca el valor del alcance.

map_reduce.scope(value: 'test')

Parámetros:

  • Objeto (Hash) (predeterminado: nulo) —

    El objeto scope.

Devuelve:

  • (MapReduce,Hash) —

    La nueva operación MapReduce o el valor del ámbito.

Desde:

  • 2.0.0



202
203
204
 
# Archivo 'lib/mongo/collection/view/map_reduce.rb', línea 202

def Alcance(Objeto = nulo)
  configurar(:alcance, Objeto)
end

#verbose(valor = nil) ⇒ MapReduce, Hash

Si se debe incluir la información de la sincronización en el resultado.

Ejemplos:

Establece el valor detallado.

map_reduce.verbose(false)

Parámetros:

  • Valor (verdadero, falso) (predeterminado: nulo) —

    Si se debe incluir la información de tiempo en el resultado.

Devuelve:

  • (MapReduce,Hash) —

    La nueva operación MapReduce o el valor de la opción de detalle.

Desde:

  • 2.0.5



218
219
220
 
# Archivo 'lib/mongo/collection/view/map_reduce.rb', línea 218

def verbose(Valor = nulo)
  configurar(:verbose, Valor)
end