Compartir a través de

Clase CepStream(TPayload)

  • Artículo

Representa un flujo de eventos de cualquier tipo de carga especificado por el usuario.

Jerarquía de herencia

System. . :: . .Object
  Microsoft.ComplexEventProcessing.Linq..::..CepStream<(Of <(<'TPayload>)>)>

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

Sintaxis

public sealed class CepStream<TPayload>

Parámetros de tipo

  • TPayload
    Tipo de carga del evento del flujo.

El tipo CepStream<(Of <(<'TPayload>)>)> expone los siguientes miembros.

Métodos

  Nombre Descripción
Método públicoMiembro estático Create(String) Crea un flujo no asociado con el tipo de carga de evento 'TPayload'.
Método públicoMiembro estático Create(Uri, EventShape) Crea un flujo enlazado en una entrada de un flujo publicado determinado.
Método públicoMiembro estático Create(Uri, EventShape, AdvanceTimeSettings) Crea un flujo enlazado para la una entrada de un flujo publicado determinado.
Método públicoMiembro estático Create(Application, Uri, EventShape) Crea un flujo enlazado en una entrada de un flujo publicado determinado.
Método públicoMiembro estático Create(String, Type, Object, EventShape) Crea un flujo enlazado a partir de un generador de adaptadores de entrada determinado.
Método públicoMiembro estático Create(Application, Uri, EventShape, AdvanceTimeSettings) Crea un flujo enlazado para la una entrada de un flujo publicado determinado.
Método públicoMiembro estático Create(String, Type, Object, EventShape, AdvanceTimeSettings) Crea un flujo enlazado a partir de un generador de adaptadores de entrada determinado.
Método públicoMiembro estático Create(Application, String, Type, Object, EventShape) Crea un flujo enlazado a partir de un generador de adaptadores de entrada determinado.
Método públicoMiembro estático Create(Application, String, Type, Object, EventShape, AdvanceTimeSettings) Crea un flujo asociado a partir de un generador de adaptadores de entrada determinado.
Método público Equals (Se hereda de Object.)
Método público ExtractInputStreams Recupera una lista con información sobre los flujos de entrada de una definición de flujo determinada.
Método protegido Finalize (Se hereda de Object.)
Método público GetHashCode (Se hereda de Object.)
Método público GetType (Se hereda de Object.)
Método protegido MemberwiseClone (Se hereda de Object.)
Método público ToPublishedStreamQuery(Uri, String, String, EventShape, StreamEventOrder) Crea una consulta con una salida enlazada a un flujo publicado denominado explícitamente. El resultado de la consulta se puede utilizar en la creación de consultas dinámicas. Solo una consulta puede producir eventos para un flujo publicado en un momento dado.
Método público ToPublishedStreamQuery(Uri, Application, String, String, EventShape, StreamEventOrder) Crea una consulta con una salida enlazada a un flujo publicado denominado explícitamente. El resultado de la consulta se puede utilizar en la creación de consultas dinámicas. Solo una consulta puede producir los eventos para un flujo publicado en un momento dado.
Método público ToQuery(String, String, EventShape, StreamEventOrder) Crea una consulta a partir del flujo con una salida desenlazada. Todas las entradas de la consulta deben estar enlazadas a adaptadores, secuencias u otras consultas. El resultado de la consulta solamente se puede usar en la creación de consultas dinámicas. La aplicación en la que se ejecutará esta consulta está implícita en la definición del flujo.
Método público ToQuery(Application, String, String, EventShape, StreamEventOrder) Crea una consulta a partir del flujo con un resultado desenlazado que se ejecuta en la aplicación especificada. Todas las entradas de la consulta deben estar enlazadas a adaptadores, secuencias u otras consultas. El resultado de la consulta solamente se puede usar en la creación de consultas dinámicas.
Método público ToQuery(String, String, Type, Object, EventShape, StreamEventOrder) Crea una consulta a partir del flujo enlazado a un adaptador de salida. El tipo de generador de adaptadores y el objeto de configuración especifican el adaptador de salida. La aplicación en la que se ejecutará esta consulta está implícita en la definición del flujo.
Método público ToQuery(String, String, Type, Object, EventShape, StreamEventOrder, Boolean) Crea una consulta a partir del flujo enlazado a un adaptador de salida. El tipo de generador de adaptadores y el objeto de configuración especifican el adaptador de salida. La aplicación en la que se ejecutará esta consulta está implícita en la definición del flujo. Se puede especificar que la consulta sea resistente.
Método público ToQuery(Application, String, String, Type, Object, EventShape, StreamEventOrder) Crea una consulta a partir del flujo enlazado a un adaptador de salida que se ejecuta en la aplicación especificada. El tipo de generador de adaptadores y el objeto de configuración especifican el adaptador de salida.
Método público ToQuery(Application, String, String, Type, Object, EventShape, StreamEventOrder, Boolean) Crea una consulta a partir del flujo enlazado a un adaptador de salida que se ejecuta en la aplicación especificada. El tipo de generador de adaptadores y el objeto de configuración especifican el adaptador de salida. Se puede especificar que la consulta sea resistente.
Método público ToString (Se hereda de Object.)

Arriba

Métodos de extensión

  Nombre Descripción
Método de extensión pública AlterEventDuration< (Of < <' (TPayload> ) > > ) Cambia la duración de los eventos de entrada. Este método no cambia la hora de inicio de un evento. (Con definición de CepStream.)
Método de extensión pública 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. (Con definición de CepStream.)
Método de extensión pública 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. (Con definición de CepStream.)
Método de extensión pública CountByStartTimeWindow< (Of < <' (TPayload> ) > > )(UInt32) Sobrecargado. 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. (Con definición de CepStream.)
Método de extensión pública CountByStartTimeWindow< (Of < <' (TPayload> ) > > )(UInt32, CountWindowOutputPolicy) Sobrecargado. 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. (Con definición de CepStream.)
Método de extensión pública CountByStartTimeWindow< (Of < <' (TPayload> ) > > )(UInt32, WindowInputPolicy, CountWindowOutputPolicy) Sobrecargado. 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. (Con definición de CepStream.)
Método de extensión pública GroupBy< (Of < <' (TPayload, TGroupingKey> ) > > )(Expression< (Of < <' (Func< (Of < <' (TPayload, TGroupingKey> ) > > )> ) > > )) Sobrecargado. Divide el flujo de entrada según la clave de agrupación especificada. (Con definición de CepStream.)
Método de extensión pública GroupBy< (Of < <' (TPayload, TGroupingKey, TResult> ) > > )(Expression< (Of < <' (Func< (Of < <' (TPayload, TGroupingKey> ) > > )> ) > > ), Expression< (Of < <' (Func< (Of < <' (TPayload, TResult> ) > > )> ) > > )) Sobrecargado. 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. (Con definición de CepStream.)
Método de extensión pública HoppingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, TimeSpan) Sobrecargado. 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. (Con definición de CepStream.)
Método de extensión pública HoppingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, TimeSpan, DateTime) Sobrecargado. 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. (Con definición de CepStream.)
Método de extensión pública HoppingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, TimeSpan, HoppingWindowOutputPolicy) Sobrecargado. 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. (Con definición de CepStream.)
Método de extensión pública HoppingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, TimeSpan, DateTime, HoppingWindowOutputPolicy) Sobrecargado. 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. (Con definición de CepStream.)
Método de extensión pública HoppingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, TimeSpan, WindowInputPolicy, HoppingWindowOutputPolicy) Sobrecargado. 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. (Con definición de CepStream.)
Método de extensión pública HoppingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, TimeSpan, DateTime, WindowInputPolicy, HoppingWindowOutputPolicy) Sobrecargado. 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. (Con definición de CepStream.)
Método de extensión pública IsEmpty< (Of < <' (TPayload> ) > > ) Función utilizada en consultas para indicar una combinación LASJ (Left Anti Semi Join). (Con definición de CepStream.)
Método de extensión pública Join< (Of < <' (TOuter, TInner, TKey, TResult> ) > > ) Combina los eventos del flujo externo con eventos del flujo interno en la clave de combinación dada. (Con definición de CepStream.)
Método de extensión pública Select< (Of < <' (TPayload, TResult> ) > > ) Proyecta los eventos del flujo de entrada utilizando una expresión de proyecciones. (Con definición de CepStream.)
Método de extensión pública SelectMany< (Of < <' (TInput, TBind, TResult> ) > > ) Produce un flujo basado en la combinación cruzada de dos flujos de entrada. (Con definición de CepStream.)
Método de extensión pública ShiftEventTime< (Of < <' (TPayload> ) > > )(Expression< (Of < <' (Func< (Of < <' (CepEvent, DateTime> ) > > )> ) > > )) Sobrecargado. Cambia la hora de inicio del evento por una nueva marca de tiempo sin cambiar la duración. (Con definición de CepStream.)
Método de extensión pública ShiftEventTime< (Of < <' (TPayload> ) > > )(Expression< (Of < <' (Func< (Of < <' (CepEvent, TimeSpan> ) > > )> ) > > )) Sobrecargado. Cambia la hora de inicio del evento por el intervalo de tiempo especificado sin cambiar la duración. (Con definición de CepStream.)
Método de extensión pública SnapshotWindow< (Of < <' (TPayload> ) > > )() () () () Sobrecargado. 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. (Con definición de CepStream.)
Método de extensión pública SnapshotWindow< (Of < <' (TPayload> ) > > )(SnapshotWindowOutputPolicy) Sobrecargado. 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. (Con definición de CepStream.)
Método de extensión pública SnapshotWindow< (Of < <' (TPayload> ) > > )(WindowInputPolicy, SnapshotWindowOutputPolicy) Sobrecargado. 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. (Con definición de CepStream.)
Método de extensión pública ToEdgeEnumerable< (Of < <' (TPayload> ) > > )() () () () Sobrecargado. Convierte un tipo CepStream de eventos perimetrales en un receptor de eventos que implementa la interfaz IEnumerable. El orden de los eventos es FullyOrdered. (Con definición de CepStream.)
Método de extensión pública ToEdgeEnumerable< (Of < <' (TPayload> ) > > )(StreamEventOrder) Sobrecargado. Convierte un tipo CepStream de eventos perimetrales con el orden de eventos especificado en un receptor de eventos que implementa la interfaz IEnumerable. (Con definición de CepStream.)
Método de extensión pública ToEdgeObservable< (Of < <' (TPayload> ) > > )() () () () Sobrecargado. Convierte un tipo CepStream de eventos perimetrales en un receptor de eventos que implementa la interfaz IObservable. El orden de los eventos es FullyOrdered. (Con definición de ObservableCepStream.)
Método de extensión pública ToEdgeObservable< (Of < <' (TPayload> ) > > )(StreamEventOrder) Sobrecargado. Convierte un tipo CepStream de eventos perimetrales con el orden de eventos especificado en un receptor de eventos que implementa la interfaz IObservable. (Con definición de ObservableCepStream.)
Método de extensión pública ToEnumerable< (Of < <' (TPayload> ) > > )() () () () Sobrecargado. Convierte un flujo de eventos en una salida enumerable quitando los encabezados de evento y descartando los eventos CTI. (Con definición de CepStream.)
Método de extensión pública ToEnumerable< (Of < <' (TPayload> ) > > )(StreamEventOrder) Sobrecargado. 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. (Con definición de CepStream.)
Método de extensión pública ToIntervalEnumerable< (Of < <' (TPayload> ) > > )() () () () Sobrecargado. 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. (Con definición de CepStream.)
Método de extensión pública ToIntervalEnumerable< (Of < <' (TPayload> ) > > )(StreamEventOrder) Sobrecargado. Convierte un tipo CepStream de eventos de intervalo con el orden de eventos especificado en un receptor de eventos que implementa la interfaz IEnumerable. (Con definición de CepStream.)
Método de extensión pública ToIntervalObservable< (Of < <' (TPayload> ) > > )() () () () Sobrecargado. Convierte un tipo CepStream de eventos de intervalo en un receptor de eventos que implementa la interfaz IObservable. El orden de los eventos es FullyOrdered. (Con definición de ObservableCepStream.)
Método de extensión pública ToIntervalObservable< (Of < <' (TPayload> ) > > )(StreamEventOrder) Sobrecargado. Convierte un tipo CepStream de eventos de intervalo con el orden de eventos especificado en un receptor de eventos que implementa la interfaz IObservable. (Con definición de ObservableCepStream.)
Método de extensión pública ToObservable< (Of < <' (TPayload> ) > > )() () () () Sobrecargado. Convierte un flujo de eventos en una salida observable quitando los encabezados de evento y descartando los eventos CTI. (Con definición de ObservableCepStream.)
Método de extensión pública ToObservable< (Of < <' (TPayload> ) > > )(StreamEventOrder) Sobrecargado. Convierte un flujo de eventos en una salida observable con el orden de eventos especificado quitando los encabezados de evento y descartando los eventos CTI. (Con definición de ObservableCepStream.)
Método de extensión pública ToPointEnumerable< (Of < <' (TPayload> ) > > )() () () () Sobrecargado. 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. (Con definición de CepStream.)
Método de extensión pública ToPointEnumerable< (Of < <' (TPayload> ) > > )(StreamEventOrder) Sobrecargado. Convierte un tipo CepStream de eventos de punto con el orden de eventos especificado en un receptor de eventos que implementa la interfaz IEnumerable. (Con definición de CepStream.)
Método de extensión pública ToPointEventStream< (Of < <' (TPayload> ) > > ) Cambia los eventos de un flujo de entrada en eventos de punto manteniendo únicamente las horas de inicio de los eventos. (Con definición de CepStream.)
Método de extensión pública ToPointObservable< (Of < <' (TPayload> ) > > )() () () () Sobrecargado. Convierte un tipo CepStream de eventos de punto en un receptor de eventos que implementa la interfaz IObservable. El orden de los eventos es FullyOrdered. (Con definición de ObservableCepStream.)
Método de extensión pública ToPointObservable< (Of < <' (TPayload> ) > > )(StreamEventOrder) Sobrecargado. Convierte un tipo CepStream de eventos de punto con el orden de eventos especificado en un receptor de eventos que implementa la interfaz IObservable. (Con definición de ObservableCepStream.)
Método de extensión pública TumblingWindow< (Of < <' (TPayload> ) > > )(TimeSpan) Sobrecargado. 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. (Con definición de CepStream.)
Método de extensión pública TumblingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, DateTime) Sobrecargado. 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. (Con definición de CepStream.)
Método de extensión pública TumblingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, HoppingWindowOutputPolicy) Sobrecargado. 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. (Con definición de CepStream.)
Método de extensión pública TumblingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, DateTime, HoppingWindowOutputPolicy) Sobrecargado. 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. (Con definición de CepStream.)
Método de extensión pública TumblingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, WindowInputPolicy, HoppingWindowOutputPolicy) Sobrecargado. 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. (Con definición de CepStream.)
Método de extensión pública TumblingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, DateTime, WindowInputPolicy, HoppingWindowOutputPolicy) Sobrecargado. 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. (Con definición de CepStream.)
Método de extensión pública Union< (Of < <' (TPayload> ) > > ) Une dos flujos en uno solo. (Con definición de CepStream.)
Método de extensión pública Where< (Of < <' (TPayload> ) > > ) Filtra los eventos de un flujo de entrada utilizando una función de filtro determinada. (Con definición de CepStream.)

Arriba

Comentarios

Antes de poder escribir una consulta CEP, debe proporcionar la definición de flujo apropiada. Esta clase incluye varios métodos para crear un objeto CepStream.

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