Compartir a través de

Clase CepStream

  • Artículo

Proporciona los métodos de extensión que se usan para escribir consultas LINQ en un flujo de eventos CEP.

Jerarquía de herencia

System. . :: . .Object
  Microsoft.ComplexEventProcessing.Linq..::..CepStream

Espacio de nombres:  Microsoft.ComplexEventProcessing.Linq
Ensamblado:  Microsoft.ComplexEventProcessing (en Microsoft.ComplexEventProcessing.dll)

Sintaxis

public static class CepStream

El tipo CepStream expone los siguientes miembros.

Métodos

  Nombre Descripción
Método públicoMiembro estático AlterEventDuration< (Of < <' (TPayload> ) > > ) Cambia la duración de los eventos de entrada. Este método no cambia la hora de inicio de un evento.
Método públicoMiembro estático AlterEventLifetime< (Of < <' (TPayload> ) > > ) Cambia la duración de los eventos del flujo. Este método puede cambiar la hora de inicio y la hora de finalización de un evento.
Método públicoMiembro estático ClipEventDuration< (Of < <' (TSource, TClip> ) > > ) Acorta la duración de los eventos de sourceStream a la hora de inicio del siguiente evento correspondiente de clipStream que coincida con matchExpression.
Método públicoMiembro estático CountByStartTimeWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), UInt32) Agrupa los eventos de flujo de entrada en ventanas de eventos en función de un número determinado de horas de inicio de evento únicas usando la directiva de salida predeterminada. La ventana se desliza cuando llega un nuevo evento que comienza en un momento diferente.
Método públicoMiembro estático CountByStartTimeWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), UInt32, CountWindowOutputPolicy) Agrupa los eventos de flujo de entrada en ventanas de eventos en función de un número determinado de horas de inicio de evento únicas. La ventana se desliza cuando llega un nuevo evento que comienza en un momento diferente.
Método públicoMiembro estático CountByStartTimeWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), UInt32, WindowInputPolicy, CountWindowOutputPolicy) Agrupa los eventos de flujo de entrada en ventanas de eventos en función de un número determinado de horas de inicio de evento únicas. La ventana se desliza cuando llega un nuevo evento que comienza en un momento diferente.
Método públicoMiembro estático GroupBy< (Of < <' (TPayload, TGroupingKey> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), Expression< (Of < <' (Func< (Of < <' (TPayload, TGroupingKey> ) > > )> ) > > )) Divide el flujo de entrada según la clave de agrupación especificada.
Método públicoMiembro estático GroupBy< (Of < <' (TPayload, TGroupingKey, TResult> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), Expression< (Of < <' (Func< (Of < <' (TPayload, TGroupingKey> ) > > )> ) > > ), Expression< (Of < <' (Func< (Of < <' (TPayload, TResult> ) > > )> ) > > )) Agrupa el flujo de origen según las funciones de selector de clave especificada y proyecta los resultados mediante la función de selector de elemento.
Método públicoMiembro estático HoppingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, TimeSpan) Transforma un flujo en un flujo de ventanas en el que cada miembro es un CepWindow usando la directiva de salida predeterminada. La ventana se define por un tamaño de ventana constante e intervalos de tamaño de salto.
Método públicoMiembro estático HoppingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, TimeSpan, HoppingWindowOutputPolicy) Transforma un flujo en un flujo de ventana donde cada miembro es una CepWindow. La ventana se define por un tamaño de ventana constante e intervalos de tamaño de salto.
Método públicoMiembro estático HoppingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, TimeSpan, DateTime) Transforma un flujo en un flujo de ventanas en el que cada miembro es un CepWindow usando la directiva de salida predeterminada. El tamaño de la ventana se define por un tamaño de ventana constante e intervalos de tamaño de salto. También puede proporcionar un tiempo de alineación como referencia para el punto inicial de la ventana.
Método públicoMiembro estático HoppingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, TimeSpan, WindowInputPolicy, HoppingWindowOutputPolicy) Transforma un flujo en un flujo de ventana donde cada miembro es una CepWindow. La ventana se define por un tamaño de ventana constante e intervalos de tamaño de salto. También puede proporcionar un tiempo de alineación como referencia para el punto inicial de la ventana.
Método públicoMiembro estático HoppingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, TimeSpan, DateTime, HoppingWindowOutputPolicy) Transforma un flujo en un flujo de ventana donde cada miembro es una CepWindow. El tamaño de la ventana se define por un tamaño de ventana constante e intervalos de tamaño de salto. También puede proporcionar un tiempo de alineación como referencia para el punto inicial de la ventana.
Método públicoMiembro estático HoppingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, TimeSpan, DateTime, WindowInputPolicy, HoppingWindowOutputPolicy) La ventana se define por un tamaño de ventana constante e intervalos de tamaño de salto. También puede proporcionar un tiempo de alineación como referencia para el punto inicial de la ventana.
Método públicoMiembro estático IsEmpty< (Of < <' (TPayload> ) > > ) Función utilizada en consultas para indicar una combinación LASJ (Left Anti Semi Join).
Método públicoMiembro estático Join< (Of < <' (TOuter, TInner, TKey, TResult> ) > > ) Combina los eventos del flujo externo con eventos del flujo interno en la clave de combinación dada.
Método públicoMiembro estático OrderBy< (Of < <' (TPayload, TOrderKey> ) > > ) Ordena el flujo de entrada según rankSelector.
Método públicoMiembro estático OrderByDescending< (Of < <' (TPayload, TOrderKey> ) > > ) Ordena el flujo de entrada según rankSelector por orden descendente.
Método públicoMiembro estático Scan< (Of < <' (TInputEvent, TInputPayload, TOutputPayload> ) > > ) Examina un flujo de entrada usando un operador de flujo definido por el usuario.
Método públicoMiembro estático Select< (Of < <' (TInput, TResult> ) > > )(CepOrderedStream< (Of < <' (TInput> ) > > ), Expression< (Of < <' (Func< (Of < <' (TInput, TResult> ) > > )> ) > > )) Dado un flujo ordenado, este método produce un flujo ordenado que se puede usar para la clasificación.
Método públicoMiembro estático Select< (Of < <' (TPayload, TResult> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), Expression< (Of < <' (Func< (Of < <' (TPayload, TResult> ) > > )> ) > > )) Proyecta los eventos del flujo de entrada utilizando una expresión de proyecciones.
Método públicoMiembro estático Select< (Of < <' (TInput, TResult> ) > > )(CepWindowStream< (Of < <' (CepWindow< (Of < <' (TInput> ) > > )> ) > > ), Expression< (Of < <' (Func< (Of < <' (CepWindow< (Of < <' (TInput> ) > > ), TResult> ) > > )> ) > > )) Asigna un flujo de ventanas a un flujo en función de una expresión de asignación determinada.
Método públicoMiembro estático Select< (Of < <' (TInput, TOutput> ) > > )(ICepEnumerable< (Of < <' (TInput> ) > > ), Expression< (Of < <' (Func< (Of < <' (TInput, TOutput> ) > > )> ) > > )) Proyecta cada evento de un flujo de entrada enumerable en un nuevo evento.
Método públicoMiembro estático SelectMany< (Of < <' (TInput, TResult> ) > > )(CepWindowStream< (Of < <' (CepWindow< (Of < <' (TInput> ) > > )> ) > > ), Expression< (Of < <' (Func< (Of < <' (CepWindow< (Of < <' (TInput> ) > > ), CepWindow< (Of < <' (TInput> ) > > )> ) > > )> ) > > ), Expression< (Of < <' (Func< (Of < <' (CepWindow< (Of < <' (TInput> ) > > ), TInput, TResult> ) > > )> ) > > )) Admite la operación de ordenar por en un flujo en ventana.
Método públicoMiembro estático SelectMany< (Of < <' (TInput, TBind, TResult> ) > > )(CepStream< (Of < <' (TInput> ) > > ), Expression< (Of < <' (Func< (Of < <' (CepStream< (Of < <' (TInput> ) > > ), CepStream< (Of < <' (TBind> ) > > )> ) > > )> ) > > ), Expression< (Of < <' (Func< (Of < <' (TInput, TBind, TResult> ) > > )> ) > > )) Produce un flujo basado en la combinación cruzada de dos flujos de entrada.
Método públicoMiembro estático SelectMany< (Of < <' (TInput, TGroupingKey, TBind, TResult> ) > > )(CepGroupingStreams< (Of < <' (TInput, TGroupingKey> ) > > ), Expression< (Of < <' (Func< (Of < <' (CepStream< (Of < <' (TInput> ) > > ), CepStream< (Of < <' (TBind> ) > > )> ) > > )> ) > > ), Expression< (Of < <' (Func< (Of < <' (IKey< (Of < <' (TGroupingKey> ) > > ), TBind, TResult> ) > > )> ) > > )) Permite agregar la lógica de la consulta en un operador para agrupar y aplicar.
Método públicoMiembro estático SelectMany< (Of < <' (TInput, TGroupingKey, TBind, TResult> ) > > )(CepGroupingStreams< (Of < <' (TInput, TGroupingKey> ) > > ), Expression< (Of < <' (Func< (Of < <' (CepStream< (Of < <' (TInput> ) > > ), CepWindowStream< (Of < <' (TBind> ) > > )> ) > > )> ) > > ), Expression< (Of < <' (Func< (Of < <' (IKey< (Of < <' (TGroupingKey> ) > > ), TBind, TResult> ) > > )> ) > > )) Produce un flujo basado en la combinación cruzada de dos flujos de entrada.
Método públicoMiembro estático ShiftEventTime< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), Expression< (Of < <' (Func< (Of < <' (CepEvent, DateTime> ) > > )> ) > > )) Cambia la hora de inicio del evento por una nueva marca de tiempo sin cambiar la duración.
Método públicoMiembro estático ShiftEventTime< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), Expression< (Of < <' (Func< (Of < <' (CepEvent, TimeSpan> ) > > )> ) > > )) Cambia la hora de inicio del evento por el intervalo de tiempo especificado sin cambiar la duración.
Método públicoMiembro estático SnapshotWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > )) Transforma un flujo en un flujo de ventanas en el que cada miembro es un CepWindow usando la directiva de salida predeterminada. Cada ventana es una ventana de instantánea definida por los extremos de evento más cercanos del flujo.
Método públicoMiembro estático SnapshotWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), SnapshotWindowOutputPolicy) Transforma un flujo en un flujo de ventana donde cada miembro es una CepWindow. Cada ventana es una ventana de instantánea definida por los extremos de evento más cercanos del flujo.
Método públicoMiembro estático SnapshotWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), WindowInputPolicy, SnapshotWindowOutputPolicy) Transforma un flujo en un flujo de ventanas donde cada miembro es un elemento CepWindow. Cada ventana es una ventana de instantánea definida por los extremos de evento más cercanos del flujo.
Método públicoMiembro estático Take< (Of < <' (TPayload> ) > > )(CepOrderedStream< (Of < <' (TPayload> ) > > ), UInt32) Dado un flujo ordenado, toma un número indicado de eventos de cada ventana.
Método públicoMiembro estático Take< (Of < <' (TInput, TResult> ) > > )(CepOrderedStream< (Of < <' (TInput> ) > > ), UInt32, Expression< (Of < <' (Func< (Of < <' (CepRankedEvent< (Of < <' (TInput> ) > > ), TResult> ) > > )> ) > > )) Toma un número especificado de eventos de cada ventana y evalúa la expresión especificada. Se utiliza en los casos en los que desea proyectar el rango en el resultado de Take().
Método públicoMiembro estático ThenBy< (Of < <' (TPayload, TOrderKey> ) > > ) Ordena un flujo ordenado según otro valor de orderKey tal y como se indica en rankSelector.
Método públicoMiembro estático ThenByDescending< (Of < <' (TPayload, TOrderKey> ) > > ) Ordena un flujo ordenado según otro valor de orderKey tal y como se indica en rankSelector.
Método públicoMiembro estático ToEdgeEnumerable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > )) Convierte un tipo CepStream de eventos perimetrales en un receptor de eventos que implementa la interfaz IEnumerable. El orden de los eventos es FullyOrdered.
Método públicoMiembro estático ToEdgeEnumerable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), StreamEventOrder) Convierte un tipo CepStream de eventos perimetrales con el orden de eventos especificado en un receptor de eventos que implementa la interfaz IEnumerable.
Método públicoMiembro estático ToEdgeStream< (Of < <' (TInput, TPayload> ) > > ) Convierte un flujo de entrada enumerable en un flujo de eventos perimetrales y proporciona las características temporales de la entrada.
Método públicoMiembro estático ToEnumerable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > )) Convierte un flujo de eventos en una salida enumerable quitando los encabezados de evento y descartando los eventos CTI.
Método públicoMiembro estático ToEnumerable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), StreamEventOrder) Convierte un flujo de eventos en una salida enumerable con el orden de eventos especificado quitando los encabezados de evento y descartando los eventos CTI.
Método públicoMiembro estático ToIntervalEnumerable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > )) Convierte un tipo CepStream de eventos de intervalo en un receptor de eventos que implementa la interfaz IEnumerable. El orden de los eventos es FullyOrdered.
Método públicoMiembro estático ToIntervalEnumerable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), StreamEventOrder) Convierte un tipo CepStream de eventos de intervalo con el orden de eventos especificado en un receptor de eventos que implementa la interfaz IEnumerable.
Método públicoMiembro estático ToIntervalStream< (Of < <' (TInput, TPayload> ) > > ) Convierte un flujo de entrada enumerable en un flujo de eventos de intervalo y proporciona las características temporales de la entrada.
Método públicoMiembro estático ToPointEnumerable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > )) Convierte un tipo CepStream de eventos de punto en un receptor de eventos que implementa la interfaz IEnumerable. El orden de los eventos es FullyOrdered.
Método públicoMiembro estático ToPointEnumerable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), StreamEventOrder) Convierte un tipo CepStream de eventos de punto con el orden de eventos especificado en un receptor de eventos que implementa la interfaz IEnumerable.
Método públicoMiembro estático ToPointEventStream< (Of < <' (TPayload> ) > > ) Cambia los eventos de un flujo de entrada en eventos de punto manteniendo únicamente las horas de inicio de los eventos.
Método públicoMiembro estático ToPointStream< (Of < <' (TInput, TPayload> ) > > )
Método públicoMiembro estático ToStream< (Of < <' (TPayload> ) > > )(IEnumerable< (Of < <' (EdgeEvent< (Of < <' (TPayload> ) > > )> ) > > ), Application, AdvanceTimeSettings, String)
Método públicoMiembro estático ToStream< (Of < <' (TPayload> ) > > )(IEnumerable< (Of < <' (IntervalEvent< (Of < <' (TPayload> ) > > )> ) > > ), Application, AdvanceTimeSettings, String)
Método públicoMiembro estático ToStream< (Of < <' (TPayload> ) > > )(IEnumerable< (Of < <' (PointEvent< (Of < <' (TPayload> ) > > )> ) > > ), Application, AdvanceTimeSettings, String)
Método públicoMiembro estático TumblingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan) Transforma un flujo en un flujo de ventanas en el que cada miembro es un CepWindow usando la directiva de salida predeterminada. Una ventana de saltos de tamaño constante es un tipo especial de ventana de salto donde el tamaño de la ventana y el tamaño de salto son iguales.
Método públicoMiembro estático TumblingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, HoppingWindowOutputPolicy) Transforma un flujo en un flujo de ventana donde cada miembro es una CepWindow. Una ventana de saltos de tamaño constante es un tipo especial de ventana de salto donde el tamaño de la ventana y tamaño del salto son iguales.
Método públicoMiembro estático TumblingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, DateTime) Transforma un flujo en un flujo de ventanas en el que cada miembro es un CepWindow usando la directiva de salida predeterminada. Una ventana de saltos de tamaño constante es un tipo especial de ventana de salto donde el tamaño de la ventana y el tamaño de salto son iguales. También puede proporcionar un tiempo de alineación como referencia para el punto inicial de la ventana.
Método públicoMiembro estático TumblingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, WindowInputPolicy, HoppingWindowOutputPolicy) Transforma un flujo en un flujo de ventana donde cada miembro es una CepWindow. Una ventana de saltos de tamaño constante es un tipo especial de ventana de salto donde el tamaño de la ventana y tamaño del salto son iguales. También puede proporcionar un tiempo de alineación como referencia para el punto inicial de la ventana.
Método públicoMiembro estático TumblingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, DateTime, HoppingWindowOutputPolicy) Transforma un flujo en un flujo de ventana donde cada miembro es una CepWindow. Una ventana de saltos de tamaño constante es un tipo especial de ventana de salto donde el tamaño de la ventana y tamaño del salto son iguales. También puede proporcionar un tiempo de alineación como referencia para el punto inicial de la ventana.
Método públicoMiembro estático TumblingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, DateTime, WindowInputPolicy, HoppingWindowOutputPolicy) Transforma un flujo en un flujo de ventana donde cada miembro es una CepWindow. Una ventana de saltos de tamaño constante es un tipo especial de ventana de salto donde el tamaño de la ventana y tamaño del salto son iguales. También puede proporcionar un tiempo de alineación como referencia para el punto inicial de la ventana.
Método públicoMiembro estático Union< (Of < <' (TPayload> ) > > ) Une dos flujos en uno solo.
Método públicoMiembro estático Where< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), Expression< (Of < <' (Func< (Of < <' (TPayload, Boolean> ) > > )> ) > > )) Filtra los eventos de un flujo de entrada utilizando una función de filtro determinada.
Método públicoMiembro estático Where< (Of < <' (TInput> ) > > )(ICepEnumerable< (Of < <' (TInput> ) > > ), Expression< (Of < <' (Func< (Of < <' (TInput, Boolean> ) > > )> ) > > )) Filtra los eventos de un flujo de entrada enumerable utilizando la expresión de filtro especificada.

Arriba

Comentarios

CepStream es una colección de los métodos de extensión. En general, los métodos de extensión devuelven una expresión de llamada a un método LINQ. Las llamadas al método capturan la secuencia de invocación en forma canónica que se traducirá posteriormente en una consulta CEP ejecutable.

Seguridad para subprocesos

Cualquier miembro público static (Shared en Visual Basic) de este tipo es seguro para subprocesos. No se garantiza que los miembros de instancia sean seguros para subprocesos.

Vea también

Referencia

Espacio de nombres Microsoft.ComplexEventProcessing.Linq