Clase: Mongo::Collection::View::Aggregation

Hereda:
Objeto
  • Objeto
Mostrar todo
Incluye:
Comportamiento
Definido en:
lib/mongo/colección/view/agregación.rb,
lib/mongo/colección/view/agregación/behavior.rb

Overview

Proporciona comportamiento alrededor de una canalización de agregación en una vista de colección.

Desde:

  • 2.0.0

Subclases conocidas directas

ChangeStream

Definido bajo Namespace

Modules: Comportamiento

Resumen constante

Constantes incluidas desde Loggable

Registrable::PREFIX

Constantes incluidas de Explicable

Explainable::ALL_PLANS_EXECUTION, Explainable::EXECUTION_STATS, Explainable::QUERY_PLANNER

Resumen de atributos de la instancia colapsar

Atributos incluidos de Comportamiento

#view

Atributos incluidos de Mongo::CursorHost

#cursor, #timeout_mode

Atributos incluidos de Inmutable

#options

Resumen del método de instancia colapsar

Métodos incluidos en Comportamiento

#allow_disk_use, #explain, #timeout_ms, #guardar?

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

Métodos incluidos en Explicable

#explain

Métodos incluidos desde Iterable

#close_query, #each

Métodos incluidos desde Mongo::CursorHost

#validate_timeout_mode!

Detalles del constructor

#initializar(vista, pipeline, opciones = {}) ⇒ Agregación

Inicializar la agregación para la vista de colección, el pipeline y las opciones proporcionadas.

Ejemplos:

Crea la nueva vista de agregación.

Aggregation.view.new(view, pipeline)

Parámetros:

  • vista (Collection::View) —

    La vista de la colección.

  • pipeline (arreglo<Hash>) —

    La tubería de operaciones.

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

    Las opciones de agregación.

Opciones Hash (options):

  • permite_uso_de_disco (verdadero, falso) —

    Establece en "true" si se permite el uso del disco durante la agregación.

  • :batch_size (Entero) —

    El número de documentos a devolver por agrupar.

  • :omitir validación de documento (verdadero, falso) —

    Si omitir o no la validación a nivel de documento.

  • :colación (Hash) —

    La intercalación para usar.

  • :comment (Objeto) —

    Un comentario proporcionado por el usuario para adjuntar a este comando.

  • :hint (Cadena) —

    El índice que se utilizará para la agregación.

  • :let (Hash) —

    Asignación de variables para usar en el pipeline. Consulta la documentación del servidor para más detalles.

  • max_time_ms (Entero) —

    El tiempo máximo en milisegundos que permite que se ejecute la agregación. Esta opción está obsoleta; utilice :timeout_ms en su lugar.

  • :: sesión (Sesión) —

    La sesión para usar.

  • :timeout_mode (:cursor_lifetime | :iteration) —

    Cómo interpretar :timeout_ms (si se aplica a la vida útil del cursor o a cada iteración).

  • :timeout_ms (Entero) —

    El tiempo de espera de la operación en milisegundos. Debe ser un número entero no negativo. Un valor explícito de 0 significa infinito. El valor por defecto no está establecido, lo que significa que se hereda de la colección, la base de datos o el cliente.

Desde:

  • 2.0.0



68
69
70
71
72
73
74
75
 
# Archivo 'lib/mongo/collection/view/aggregation.rb', línea 68

def inicializar(vista, pipeline, opciones = {})
  performar_setup(vista, opciones) hacer
    @pipeline = pipeline.dup
    a menos que Mongo.broken_view_aggregate || vista.filtro.¿vacío?
      @pipeline.unshift(:$match => vista.filtro)
    end
  end
end

Detalles de los atributos de instancia

#pipeline ⇒ arreglo<Hash> (solo lectura)

Devuelve la canalización La canalización de agregación.

Devuelve:

  • (arreglo<Hash>) —

    pipeline El pipeline de agregación.

Desde:

  • 2.0.0



31
32
33
 
# Archivo 'lib/mongo/collection/view/aggregation.rb', línea 31

def pipeline
  @pipeline
end