Compartilhar via

Classe CepStream(TPayload)

  • Artigo

Representa um fluxo de eventos de qualquer tipo de carga especificado pelo usuário.

Hierarquia de herança

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

Namespace:  Microsoft.ComplexEventProcessing.Linq
Assembly:  Microsoft.ComplexEventProcessing (em Microsoft.ComplexEventProcessing.dll)

Sintaxe

public sealed class CepStream<TPayload>

Parâmetros de tipo

  • TPayload
    Tipo de carga do evento no fluxo.

O tipo CepStream<(Of <(<'TPayload>)>)> expõe os membros a seguir.

Métodos

  Nome Descrição
Método públicoMembro estático Create(String) Cria um fluxo não associado com carga de evento do tipo 'TPayload'.
Método públicoMembro estático Create(Uri, EventShape) Cria um fluxo associado sobre uma entrada de um determinado fluxo publicado.
Método públicoMembro estático Create(Uri, EventShape, AdvanceTimeSettings) Cria um fluxo associado para entrada de um determinado fluxo publicado.
Método públicoMembro estático Create(Application, Uri, EventShape) Cria um fluxo associado sobre uma entrada de um determinado fluxo publicado.
Método públicoMembro estático Create(String, Type, Object, EventShape) Cria um fluxo associado a partir de determinada fábrica de adaptador de entrada.
Método públicoMembro estático Create(Application, Uri, EventShape, AdvanceTimeSettings) Cria um fluxo associado para entrada de um determinado fluxo publicado.
Método públicoMembro estático Create(String, Type, Object, EventShape, AdvanceTimeSettings) Cria um fluxo associado a partir de uma determinada fábrica de adaptador de entrada.
Método públicoMembro estático Create(Application, String, Type, Object, EventShape) Cria um fluxo associado a partir de determinada fábrica de adaptador de entrada.
Método públicoMembro estático Create(Application, String, Type, Object, EventShape, AdvanceTimeSettings) Cria um fluxo associado a partir de determinada fábrica de adaptador de entrada.
Método público Equals (Herdado de Object.)
Método público ExtractInputStreams Recupera uma lista com informações sobre fluxos de entrada de uma determinada definição de fluxo.
Método protegido Finalize (Herdado de Object.)
Método público GetHashCode (Herdado de Object.)
Método público GetType (Herdado de Object.)
Método protegido MemberwiseClone (Herdado de Object.)
Método público ToPublishedStreamQuery(Uri, String, String, EventShape, StreamEventOrder) Cria uma consulta com uma saída associada a um fluxo publicado explicitamente nomeado. A saída da consulta pode ser consumida por meio da composição de consulta dinâmica. Somente uma consulta pode produzir eventos para um fluxo publicado a qualquer momento.
Método público ToPublishedStreamQuery(Uri, Application, String, String, EventShape, StreamEventOrder) Cria uma consulta com uma saída associada a um fluxo publicado explicitamente nomeado. A saída da consulta pode ser consumida por meio da composição de consulta dinâmica. Somente uma consulta pode produzir eventos para um fluxo publicado a qualquer momento.
Método público ToQuery(String, String, EventShape, StreamEventOrder) Cria uma consulta do fluxo com uma saída não associada. Todas as entradas para a consulta devem ser associadas a adaptadores, sequências ou outras consultas. A saída da consulta pode ser consumida somente por meio da composição de consulta dinâmica. O aplicativo em que esta consulta será executada está implícito na definição do fluxo.
Método público ToQuery(Application, String, String, EventShape, StreamEventOrder) Cria uma consulta do fluxo com uma saída não associada em execução no aplicativo especificado. Todas as entradas para a consulta devem ser associadas a adaptadores, sequências ou outras consultas. A saída da consulta pode ser consumida somente por meio da composição de consulta dinâmica.
Método público ToQuery(String, String, Type, Object, EventShape, StreamEventOrder) Cria uma consulta do fluxo associado a um adaptador de saída. O adaptador de saída é especificado pelo tipo da fábrica do adaptador e do objeto de configuração. O aplicativo em que esta consulta será executada está implícito na definição do fluxo.
Método público ToQuery(String, String, Type, Object, EventShape, StreamEventOrder, Boolean) Cria uma consulta do fluxo associado a um adaptador de saída. O adaptador de saída é especificado pelo tipo da fábrica do adaptador e do objeto de configuração. O aplicativo em que esta consulta será executada está implícito na definição do fluxo. A consulta pode ser especificada para ser resiliente.
Método público ToQuery(Application, String, String, Type, Object, EventShape, StreamEventOrder) Cria uma consulta do fluxo associado a um adaptador de saída em execução no aplicativo especificado. O adaptador de saída é especificado pelo tipo da fábrica do adaptador e do objeto de configuração.
Método público ToQuery(Application, String, String, Type, Object, EventShape, StreamEventOrder, Boolean) Cria uma consulta do fluxo associado a um adaptador de saída em execução no aplicativo especificado. O adaptador de saída é especificado pelo tipo da fábrica do adaptador e do objeto de configuração. A consulta pode ser especificada para ser resiliente.
Método público ToString (Herdado de Object.)

Início

Métodos de extensão

  Nome Descrição
Método de extensão público AlterEventDuration< (Of < <' (TPayload> ) > > ) Altera a duração dos eventos de entrada. Esse método não altera a hora de início de um evento. (Definido por CepStream.)
Método de extensão público AlterEventLifetime< (Of < <' (TPayload> ) > > ) Altera o tempo de vida dos eventos no fluxo. Esse método pode alterar as horas de início e de término de um evento. (Definido por CepStream.)
Método de extensão público ClipEventDuration< (Of < <' (TSource, TClip> ) > > ) Reduz o tempo de vida dos eventos em sourceStream ao tempo inicial do próximo evento correspondente em clipStream que tenha correspondência com matchExpression. (Definido por CepStream.)
Método de extensão público CountByStartTimeWindow< (Of < <' (TPayload> ) > > )(UInt32) Sobrecarregado. Agrupa eventos de fluxo de entrada em janelas de eventos com base em determinado número de horas de início de evento exclusivas usando a política de saída padrão. A janela desliza quando chega um novo evento que inicia em outro horário. (Definido por CepStream.)
Método de extensão público CountByStartTimeWindow< (Of < <' (TPayload> ) > > )(UInt32, CountWindowOutputPolicy) Sobrecarregado. Agrupa eventos de fluxo de entrada em janelas de eventos com base em um determinado número de horas de início de evento exclusivas. A janela desliza quando chega um novo evento que inicia em outro horário. (Definido por CepStream.)
Método de extensão público CountByStartTimeWindow< (Of < <' (TPayload> ) > > )(UInt32, WindowInputPolicy, CountWindowOutputPolicy) Sobrecarregado. Agrupa eventos de fluxo de entrada em janelas de eventos com base em um determinado número de horas de início de evento exclusivas. A janela desliza quando chega um novo evento que inicia em outro horário. (Definido por CepStream.)
Método de extensão público GroupBy< (Of < <' (TPayload, TGroupingKey> ) > > )(Expression< (Of < <' (Func< (Of < <' (TPayload, TGroupingKey> ) > > )> ) > > )) Sobrecarregado. Particiona o fluxo de entrada pela chave de agrupamento especificada. (Definido por CepStream.)
Método de extensão público GroupBy< (Of < <' (TPayload, TGroupingKey, TResult> ) > > )(Expression< (Of < <' (Func< (Of < <' (TPayload, TGroupingKey> ) > > )> ) > > ), Expression< (Of < <' (Func< (Of < <' (TPayload, TResult> ) > > )> ) > > )) Sobrecarregado. Agrupa o fluxo de origem pelas funções de seletor de chave especificadas e projeta resultados usando a função de seletor de elemento. (Definido por CepStream.)
Método de extensão público HoppingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, TimeSpan) Sobrecarregado. Transforma um fluxo em um fluxo de janela onde cada membro é um CepWindow usando a política de saída padrão. A janela é definida pelo tamanho constante da janela e pelas durações do tamanho de salto. (Definido por CepStream.)
Método de extensão público HoppingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, TimeSpan, DateTime) Sobrecarregado. Transforma um fluxo em um fluxo de janela onde cada membro é um CepWindow usando a política de saída padrão. A janela é definida pelo tamanho constante da janela e pelas durações do tamanho de salto. Você também pode fornecer um tempo de alinhamento como uma referência para o ponto de partida da janela. (Definido por CepStream.)
Método de extensão público HoppingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, TimeSpan, HoppingWindowOutputPolicy) Sobrecarregado. Transforma um fluxo em um fluxo de janela onde cada membro é um CepWindow. A janela é definida pelo tamanho constante da janela e pelas durações do tamanho de salto. (Definido por CepStream.)
Método de extensão público HoppingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, TimeSpan, DateTime, HoppingWindowOutputPolicy) Sobrecarregado. Transforma um fluxo em um fluxo de janela onde cada membro é um CepWindow. A janela é definida pelo tamanho constante da janela e pelas durações do tamanho de salto. Você também pode fornecer um tempo de alinhamento como uma referência para o ponto de partida da janela. (Definido por CepStream.)
Método de extensão público HoppingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, TimeSpan, WindowInputPolicy, HoppingWindowOutputPolicy) Sobrecarregado. Transforma um fluxo em um fluxo de janela onde cada membro é um CepWindow. A janela é definida pelo tamanho constante da janela e pelas durações do tamanho de salto. Você também pode fornecer um tempo de alinhamento como uma referência para o ponto de partida da janela. (Definido por CepStream.)
Método de extensão público HoppingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, TimeSpan, DateTime, WindowInputPolicy, HoppingWindowOutputPolicy) Sobrecarregado. A janela é definida pelo tamanho constante da janela e pelas durações do tamanho de salto. Você também pode fornecer um tempo de alinhamento como uma referência para o ponto de partida da janela. (Definido por CepStream.)
Método de extensão público IsEmpty< (Of < <' (TPayload> ) > > ) Função usada em consultas para indicar um LASJ (antissemijunção esquerda). (Definido por CepStream.)
Método de extensão público Join< (Of < <' (TOuter, TInner, TKey, TResult> ) > > ) Une os eventos do fluxo externo a eventos do fluxo interno em uma determinada chave de junção. (Definido por CepStream.)
Método de extensão público Select< (Of < <' (TPayload, TResult> ) > > ) Projeta eventos do fluxo de entrada usando uma expressão de projeções. (Definido por CepStream.)
Método de extensão público SelectMany< (Of < <' (TInput, TBind, TResult> ) > > ) Gera um fluxo baseado na junção cruzada de dois fluxos de entrada. (Definido por CepStream.)
Método de extensão público ShiftEventTime< (Of < <' (TPayload> ) > > )(Expression< (Of < <' (Func< (Of < <' (CepEvent, DateTime> ) > > )> ) > > )) Sobrecarregado. Desloca a hora de início do evento para um novo carimbo de data/hora sem alterar o tempo de vida. (Definido por CepStream.)
Método de extensão público ShiftEventTime< (Of < <' (TPayload> ) > > )(Expression< (Of < <' (Func< (Of < <' (CepEvent, TimeSpan> ) > > )> ) > > )) Sobrecarregado. Desloca a hora de início do evento pelo período de tempo especificado sem alterar o tempo de vida. (Definido por CepStream.)
Método de extensão público SnapshotWindow< (Of < <' (TPayload> ) > > )() () () () Sobrecarregado. Transforma um fluxo em um fluxo de janela onde cada membro é um CepWindow usando a política de saída padrão. Cada janela é uma janela de instantâneo que é definida pelos pontos de extremidade do evento mais próximo no fluxo. (Definido por CepStream.)
Método de extensão público SnapshotWindow< (Of < <' (TPayload> ) > > )(SnapshotWindowOutputPolicy) Sobrecarregado. Transforma um fluxo em um fluxo de janela onde cada membro é um CepWindow. Cada janela é uma janela de instantâneo definida pelos pontos de extremidade de evento mais próximos no fluxo. (Definido por CepStream.)
Método de extensão público SnapshotWindow< (Of < <' (TPayload> ) > > )(WindowInputPolicy, SnapshotWindowOutputPolicy) Sobrecarregado. Transforma um fluxo em um fluxo de janela onde cada membro é um CepWindow. Cada janela é uma janela de instantâneo definida pelos pontos de extremidade de evento mais próximos no fluxo. (Definido por CepStream.)
Método de extensão público ToEdgeEnumerable< (Of < <' (TPayload> ) > > )() () () () Sobrecarregado. Converte um CepStream de eventos de borda em um coletor de eventos que implementa a interface IEnumerable. A ordem dos eventos é FullyOrdered. (Definido por CepStream.)
Método de extensão público ToEdgeEnumerable< (Of < <' (TPayload> ) > > )(StreamEventOrder) Sobrecarregado. Converte um CepStream de eventos de borda com a ordem de eventos especificada em um coletor de eventos que implementa a interface IEnumerable. (Definido por CepStream.)
Método de extensão público ToEdgeObservable< (Of < <' (TPayload> ) > > )() () () () Sobrecarregado. Converte um CepStream de eventos de borda em um coletor de eventos que implementa a interface IObservable. A ordem dos eventos é FullyOrdered. (Definido por ObservableCepStream.)
Método de extensão público ToEdgeObservable< (Of < <' (TPayload> ) > > )(StreamEventOrder) Sobrecarregado. Converte um CepStream de eventos de borda com a ordem de eventos especificada em um coletor de eventos que implementa a interface IObservable. (Definido por ObservableCepStream.)
Método de extensão público ToEnumerable< (Of < <' (TPayload> ) > > )() () () () Sobrecarregado. Converte um fluxo de eventos em uma saída enumerável removendo cabeçalhos de eventos e descartando eventos CTI. (Definido por CepStream.)
Método de extensão público ToEnumerable< (Of < <' (TPayload> ) > > )(StreamEventOrder) Sobrecarregado. Converte um fluxo de eventos em uma saída enumerável com a ordem de eventos especificada, removendo cabeçalhos de eventos e descartando eventos CTI. (Definido por CepStream.)
Método de extensão público ToIntervalEnumerable< (Of < <' (TPayload> ) > > )() () () () Sobrecarregado. Converte um CepStream de eventos de intervalo em um coletor de eventos que implementa a interface IEnumerable. A ordem dos eventos é FullyOrdered. (Definido por CepStream.)
Método de extensão público ToIntervalEnumerable< (Of < <' (TPayload> ) > > )(StreamEventOrder) Sobrecarregado. Converte um CepStream de eventos de intervalo com a ordem de eventos especificada em um coletor de eventos que implementa a interface IEnumerable. (Definido por CepStream.)
Método de extensão público ToIntervalObservable< (Of < <' (TPayload> ) > > )() () () () Sobrecarregado. Converte um CepStream de eventos de intervalo em um coletor de eventos que implementa a interface IObservable. A ordem dos eventos é FullyOrdered. (Definido por ObservableCepStream.)
Método de extensão público ToIntervalObservable< (Of < <' (TPayload> ) > > )(StreamEventOrder) Sobrecarregado. Converte um CepStream de eventos de intervalo com a ordem de eventos especificada em um coletor de eventos que implementa a interface IObservable. (Definido por ObservableCepStream.)
Método de extensão público ToObservable< (Of < <' (TPayload> ) > > )() () () () Sobrecarregado. Converte um fluxo de eventos em uma saída observável removendo cabeçalhos de eventos e descartando eventos CTI. (Definido por ObservableCepStream.)
Método de extensão público ToObservable< (Of < <' (TPayload> ) > > )(StreamEventOrder) Sobrecarregado. Converte um fluxo de eventos em uma saída observável com a ordem de eventos especificada, removendo cabeçalhos de eventos e descartando eventos CTI. (Definido por ObservableCepStream.)
Método de extensão público ToPointEnumerable< (Of < <' (TPayload> ) > > )() () () () Sobrecarregado. Converte um CepStream de eventos pontuais em um coletor de eventos que implementa a interface IEnumerable. A ordem dos eventos é FullyOrdered. (Definido por CepStream.)
Método de extensão público ToPointEnumerable< (Of < <' (TPayload> ) > > )(StreamEventOrder) Sobrecarregado. Converte um CepStream de eventos pontuais com a ordem de eventos especificada em um coletor de eventos que implementa a interface IEnumerable. (Definido por CepStream.)
Método de extensão público ToPointEventStream< (Of < <' (TPayload> ) > > ) Altera os eventos em um fluxo de entrada para eventos pontuais mantendo apenas as horas de início dos eventos. (Definido por CepStream.)
Método de extensão público ToPointObservable< (Of < <' (TPayload> ) > > )() () () () Sobrecarregado. Converte um CepStream de eventos pontuais em um coletor de eventos que implementa a interface IObservable. A ordem dos eventos é FullyOrdered. (Definido por ObservableCepStream.)
Método de extensão público ToPointObservable< (Of < <' (TPayload> ) > > )(StreamEventOrder) Sobrecarregado. Converte um CepStream de eventos pontuais com a ordem de eventos especificada em um coletor de eventos que implementa a interface IObservable. (Definido por ObservableCepStream.)
Método de extensão público TumblingWindow< (Of < <' (TPayload> ) > > )(TimeSpan) Sobrecarregado. Transforma um fluxo em um fluxo de janela onde cada membro é um CepWindow usando a política de saída padrão. Uma janela em cascata é um tipo especial de janela de salto na qual o tamanho da janela e o tamanho do salto são iguais. (Definido por CepStream.)
Método de extensão público TumblingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, DateTime) Sobrecarregado. Transforma um fluxo em um fluxo de janela onde cada membro é um CepWindow usando a política de saída padrão. Uma janela em cascata é um tipo especial de janela de salto na qual o tamanho da janela e o tamanho do salto são iguais. Você também pode fornecer um tempo de alinhamento como uma referência para o ponto de partida da janela. (Definido por CepStream.)
Método de extensão público TumblingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, HoppingWindowOutputPolicy) Sobrecarregado. Transforma um fluxo em um fluxo de janela onde cada membro é um CepWindow. Uma janela em cascata é um tipo especial de janela de salto na qual o tamanho da janela e o tamanho do salto são iguais. (Definido por CepStream.)
Método de extensão público TumblingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, DateTime, HoppingWindowOutputPolicy) Sobrecarregado. Transforma um fluxo em um fluxo de janela onde cada membro é um CepWindow. Uma janela em cascata é um tipo especial de janela de salto na qual o tamanho da janela e o tamanho do salto são iguais. Você também pode fornecer um tempo de alinhamento como uma referência para o ponto de partida da janela. (Definido por CepStream.)
Método de extensão público TumblingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, WindowInputPolicy, HoppingWindowOutputPolicy) Sobrecarregado. Transforma um fluxo em um fluxo de janela onde cada membro é um CepWindow. Uma janela em cascata é um tipo especial de janela de salto na qual o tamanho da janela e o tamanho do salto são iguais. Você também pode fornecer um tempo de alinhamento como uma referência para o ponto de partida da janela. (Definido por CepStream.)
Método de extensão público TumblingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, DateTime, WindowInputPolicy, HoppingWindowOutputPolicy) Sobrecarregado. Transforma um fluxo em um fluxo de janela onde cada membro é um CepWindow. Uma janela em cascata é um tipo especial de janela de salto na qual o tamanho da janela e o tamanho do salto são iguais. Você também pode fornecer um tempo de alinhamento como uma referência para o ponto de partida da janela. (Definido por CepStream.)
Método de extensão público Union< (Of < <' (TPayload> ) > > ) Une dois fluxos em um único fluxo. (Definido por CepStream.)
Método de extensão público Where< (Of < <' (TPayload> ) > > ) Filtra eventos de um fluxo de entrada usando uma determinada função de filtro. (Definido por CepStream.)

Início

Comentários

Antes de escrever uma consulta CEP, você deve fornecer a definição de fluxo apropriada. Essa classe fornece vários métodos para criação de um objeto CepStream.

Segurança de thread

Qualquer membro público static (Shared no Visual Basic) desse tipo é seguro para threads. Não há garantia de que qualquer membro de instância seja seguro para threads.

Consulte também

Referência

Namespace Microsoft.ComplexEventProcessing.Linq