Compartilhar via

Classe CepStream

  • Artigo

Fornece os métodos de extensão usados para gravar consultas LINQ em um fluxo de eventos CEP.

Hierarquia de herança

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

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

Sintaxe

public static class CepStream

O tipo CepStream expõe os membros a seguir.

Métodos

  Nome Descrição
Método públicoMembro estático 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.
Método públicoMembro estático 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.
Método públicoMembro estático 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.
Método públicoMembro estático CountByStartTimeWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), UInt32) 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.
Método públicoMembro estático CountByStartTimeWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), UInt32, CountWindowOutputPolicy) 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.
Método públicoMembro estático CountByStartTimeWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), UInt32, WindowInputPolicy, CountWindowOutputPolicy) 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.
Método públicoMembro estático GroupBy< (Of < <' (TPayload, TGroupingKey> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), Expression< (Of < <' (Func< (Of < <' (TPayload, TGroupingKey> ) > > )> ) > > )) Particiona o fluxo de entrada pela chave de agrupamento especificada.
Método públicoMembro estático GroupBy< (Of < <' (TPayload, TGroupingKey, TResult> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), Expression< (Of < <' (Func< (Of < <' (TPayload, TGroupingKey> ) > > )> ) > > ), Expression< (Of < <' (Func< (Of < <' (TPayload, TResult> ) > > )> ) > > )) Agrupa o fluxo de origem pelas funções de seletor de chave especificadas e projeta resultados usando a função de seletor de elemento.
Método públicoMembro estático HoppingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, TimeSpan) 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.
Método públicoMembro estático HoppingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, TimeSpan, HoppingWindowOutputPolicy) 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.
Método públicoMembro estático HoppingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, TimeSpan, DateTime) 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.
Método públicoMembro estático HoppingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, TimeSpan, WindowInputPolicy, HoppingWindowOutputPolicy) 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.
Método públicoMembro estático HoppingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, TimeSpan, DateTime, HoppingWindowOutputPolicy) 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.
Método públicoMembro estático HoppingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, TimeSpan, DateTime, WindowInputPolicy, HoppingWindowOutputPolicy) 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.
Método públicoMembro estático IsEmpty< (Of < <' (TPayload> ) > > ) Função usada em consultas para indicar um LASJ (antissemijunção esquerda).
Método públicoMembro estático Join< (Of < <' (TOuter, TInner, TKey, TResult> ) > > ) Une os eventos do fluxo externo a eventos do fluxo interno em uma determinada chave de junção.
Método públicoMembro estático OrderBy< (Of < <' (TPayload, TOrderKey> ) > > ) Ordena o fluxo de entrada por rankSelector.
Método públicoMembro estático OrderByDescending< (Of < <' (TPayload, TOrderKey> ) > > ) Ordena o fluxo de entrada por rankSelector em ordem decrescente.
Método públicoMembro estático Scan< (Of < <' (TInputEvent, TInputPayload, TOutputPayload> ) > > ) Examina um fluxo de entrada usando um operador de fluxo definido pelo usuário.
Método públicoMembro estático Select< (Of < <' (TInput, TResult> ) > > )(CepOrderedStream< (Of < <' (TInput> ) > > ), Expression< (Of < <' (Func< (Of < <' (TInput, TResult> ) > > )> ) > > )) Dado um fluxo ordenado, este método gera um fluxo ordenado que pode ser usado para classificação.
Método públicoMembro estático Select< (Of < <' (TPayload, TResult> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), Expression< (Of < <' (Func< (Of < <' (TPayload, TResult> ) > > )> ) > > )) Projeta eventos do fluxo de entrada usando uma expressão de projeções.
Método públicoMembro estático Select< (Of < <' (TInput, TResult> ) > > )(CepWindowStream< (Of < <' (CepWindow< (Of < <' (TInput> ) > > )> ) > > ), Expression< (Of < <' (Func< (Of < <' (CepWindow< (Of < <' (TInput> ) > > ), TResult> ) > > )> ) > > )) Mapeia um fluxo de janela para um fluxo baseado em uma determinada expressão de mapeamento.
Método públicoMembro estático Select< (Of < <' (TInput, TOutput> ) > > )(ICepEnumerable< (Of < <' (TInput> ) > > ), Expression< (Of < <' (Func< (Of < <' (TInput, TOutput> ) > > )> ) > > )) Projeta cada evento de um fluxo de entrada enumerável em um novo evento.
Método públicoMembro 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> ) > > )> ) > > )) Oferece suporte à ordenação por operador em um fluxo em janelas.
Método públicoMembro 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> ) > > )> ) > > )) Gera um fluxo baseado na junção cruzada de dois fluxos de entrada.
Método públicoMembro 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> ) > > )> ) > > )) Oferece suporte à adição da lógica de consulta em um operador Agrupar e Aplicar.
Método públicoMembro 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> ) > > )> ) > > )) Gera um fluxo baseado na junção cruzada de dois fluxos de entrada.
Método públicoMembro estático ShiftEventTime< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), Expression< (Of < <' (Func< (Of < <' (CepEvent, DateTime> ) > > )> ) > > )) Desloca a hora de início do evento para um novo carimbo de data/hora sem alterar o tempo de vida.
Método públicoMembro estático ShiftEventTime< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), Expression< (Of < <' (Func< (Of < <' (CepEvent, TimeSpan> ) > > )> ) > > )) Desloca a hora de início do evento pelo período de tempo especificado sem alterar o tempo de vida.
Método públicoMembro estático SnapshotWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > )) 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.
Método públicoMembro estático SnapshotWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), SnapshotWindowOutputPolicy) 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.
Método públicoMembro estático SnapshotWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), WindowInputPolicy, SnapshotWindowOutputPolicy) 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.
Método públicoMembro estático Take< (Of < <' (TPayload> ) > > )(CepOrderedStream< (Of < <' (TPayload> ) > > ), UInt32) Dado um fluxo ordenado, toma um determinado número de eventos de cada janela.
Método públicoMembro estático Take< (Of < <' (TInput, TResult> ) > > )(CepOrderedStream< (Of < <' (TInput> ) > > ), UInt32, Expression< (Of < <' (Func< (Of < <' (CepRankedEvent< (Of < <' (TInput> ) > > ), TResult> ) > > )> ) > > )) Obtém um determinado número de eventos de cada janela e também avalia a expressão especificada. É usado nos casos em que você deseja projetar a classificação no resultado de Take().
Método públicoMembro estático ThenBy< (Of < <' (TPayload, TOrderKey> ) > > ) Ordena um fluxo ordenado por outra orderKey conforme indicado por rankSelector.
Método públicoMembro estático ThenByDescending< (Of < <' (TPayload, TOrderKey> ) > > ) Ordena um fluxo ordenado por outra orderKey conforme indicado por rankSelector.
Método públicoMembro estático ToEdgeEnumerable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > )) Converte um CepStream de eventos de borda em um coletor de eventos que implementa a interface IEnumerable. A ordem dos eventos é FullyOrdered.
Método públicoMembro estático ToEdgeEnumerable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), StreamEventOrder) Converte um CepStream de eventos de borda com a ordem de eventos especificada em um coletor de eventos que implementa a interface IEnumerable.
Método públicoMembro estático ToEdgeStream< (Of < <' (TInput, TPayload> ) > > ) Converte um fluxo de entrada enumerável em um fluxo de eventos de borda, e fornece as características temporais da entrada.
Método públicoMembro estático ToEnumerable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > )) Converte um fluxo de eventos em uma saída enumerável removendo cabeçalhos de eventos e descartando eventos CTI.
Método públicoMembro estático ToEnumerable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), StreamEventOrder) 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.
Método públicoMembro estático ToIntervalEnumerable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > )) Converte um CepStream de eventos de intervalo em um coletor de eventos que implementa a interface IEnumerable. A ordem dos eventos é FullyOrdered.
Método públicoMembro estático ToIntervalEnumerable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), StreamEventOrder) Converte um CepStream de eventos de intervalo com a ordem de eventos especificada em um coletor de eventos que implementa a interface IEnumerable.
Método públicoMembro estático ToIntervalStream< (Of < <' (TInput, TPayload> ) > > ) Converte um fluxo de entrada enumerável em um fluxo de eventos de intervalo, e fornece as características temporais da entrada.
Método públicoMembro estático ToPointEnumerable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > )) Converte um CepStream de eventos pontuais em um coletor de eventos que implementa a interface IEnumerable. A ordem dos eventos é FullyOrdered.
Método públicoMembro estático ToPointEnumerable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), StreamEventOrder) Converte um CepStream de eventos pontuais com a ordem de eventos especificada em um coletor de eventos que implementa a interface IEnumerable.
Método públicoMembro estático ToPointEventStream< (Of < <' (TPayload> ) > > ) Altera os eventos em um fluxo de entrada para eventos pontuais mantendo apenas as horas de início dos eventos.
Método públicoMembro estático ToPointStream< (Of < <' (TInput, TPayload> ) > > )
Método públicoMembro estático ToStream< (Of < <' (TPayload> ) > > )(IEnumerable< (Of < <' (EdgeEvent< (Of < <' (TPayload> ) > > )> ) > > ), Application, AdvanceTimeSettings, String)
Método públicoMembro estático ToStream< (Of < <' (TPayload> ) > > )(IEnumerable< (Of < <' (IntervalEvent< (Of < <' (TPayload> ) > > )> ) > > ), Application, AdvanceTimeSettings, String)
Método públicoMembro estático ToStream< (Of < <' (TPayload> ) > > )(IEnumerable< (Of < <' (PointEvent< (Of < <' (TPayload> ) > > )> ) > > ), Application, AdvanceTimeSettings, String)
Método públicoMembro estático TumblingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan) 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.
Método públicoMembro estático TumblingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, HoppingWindowOutputPolicy) 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.
Método públicoMembro estático TumblingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, DateTime) 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.
Método públicoMembro estático TumblingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, WindowInputPolicy, HoppingWindowOutputPolicy) 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.
Método públicoMembro estático TumblingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, DateTime, HoppingWindowOutputPolicy) 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.
Método públicoMembro estático TumblingWindow< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), TimeSpan, DateTime, WindowInputPolicy, HoppingWindowOutputPolicy) 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.
Método públicoMembro estático Union< (Of < <' (TPayload> ) > > ) Une dois fluxos em um único fluxo.
Método públicoMembro estático Where< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), Expression< (Of < <' (Func< (Of < <' (TPayload, Boolean> ) > > )> ) > > )) Filtra eventos de um fluxo de entrada usando uma determinada função de filtro.
Método públicoMembro estático Where< (Of < <' (TInput> ) > > )(ICepEnumerable< (Of < <' (TInput> ) > > ), Expression< (Of < <' (Func< (Of < <' (TInput, Boolean> ) > > )> ) > > )) Filtra eventos de um fluxo de entrada enumerável usando a expressão de filtro especificada.

Início

Comentários

CepStream é uma coleção de métodos de extensão. Em geral, os métodos da extensão retornam uma expressão de chamada de método LINQ. As chamadas do método capturam a sequência de invocação em uma forma canônica posteriormente convertida em uma consulta CEP executável.

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