Namespace Microsoft.ComplexEventProcessing.Linq

Expõe a linguagem do modelo de consulta do StreamInsight. Para obter mais informações, consulte Gravando modelos de consulta no LINQ.

Classes

  Classe Descrição
Classe pública CepEvent Fornece acesso à hora de início com expressões que podem fazer referência apenas à hora de início de um evento.
Classe pública CepEvent< (Of < ( <'TPayload> ) > ) > Permite especificar expressões lambda para alterações de duração de evento. Fornece acesso à hora de início, à hora de término e à carga do evento.
Classe pública CepGroupingStreams< (Of < ( <'TPayload, TGroupingKey> ) > ) > Representa um grupo de fluxos.
Classe pública CepOrderableStream< (Of < ( <'T> ) > ) > Representa um fluxo de eventos que podem ser ordenados.
Classe pública CepOrderedStream< (Of < ( <'T> ) > ) > Um fluxo ordenado é o resultado de "order by" ou de uma de suas variações na consulta. Ele ajuda a restringir a especificação de consulta subsequente a operações que são permitidas em um fluxo ordenado, como Take.
Classe pública CepRankedEvent< (Of < ( <'P> ) > ) > Expõe uma classificação junto com a carga do evento sobre um fluxo classificado usando Take.
Classe pública CepStream Fornece os métodos de extensão usados para gravar consultas LINQ em um fluxo de eventos CEP.
Classe pública CepStream< (Of < ( <'TPayload> ) > ) > Representa um fluxo de eventos de qualquer tipo de carga especificado pelo usuário.
Classe pública CepStreamConsumer< (Of < ( <'T> ) > ) > CepStreamConsumer representa uma informação específica de consumidor de fluxo. Ele será convertido em associação de saída real para uma consulta.
Classe pública CepStreamCreationContext Esta classe representa o contexto no qual um CepStream foi criado.
Classe pública CepUserDefinedAggregateAttribute Decora o método de extensão de agregação definida pelo usuário.
Classe pública CepUserDefinedOperatorAttribute Decora o método de extensão de operador definido pelo usuário.
Classe pública CepUtility Classe de utilitário usada por operadores, agregações e funções definidos pelo usuário.
Classe pública CepWindow< (Of < ( <'TPayload> ) > ) > Uma janela é uma coleção finita de eventos que resulta da aplicação de um operador em janela em um fluxo de eventos.
Classe pública CepWindowExtensionMethods Métodos de extensão para agregações internas.
Classe pública CepWindowStream< (Of < ( <'T> ) > ) > Resulta da aplicação de um operador em janela a um fluxo.
Classe pública CountWindowOutputPolicy Define as políticas de saída da janela que são aplicáveis às janelas de contagem. A política de saída da janela descreve como o mecanismo CEP modifica o carimbo de data/hora de eventos que resultam de uma operação baseada em janela.
Classe pública HoppingWindowOutputPolicy Define as políticas de saída da janela que são aplicáveis às janelas de salto. Uma política de saída da janela descreve como o mecanismo CEP modifica a indicação de data e hora dos eventos resultantes de uma operação baseada em janela.
Classe pública InputStreamInfo Contém todas as informações extraídas de uma definição de fluxo.
Classe pública ObservableCepStream Oferece suporte a coletores de eventos que implementam a interface IObservable.
Classe pública QueryGenerationException Exceção lançada do provedor LINQ quando a consulta não pode ser gerada corretamente.
Classe pública SnapshotWindowOutputPolicy Define as políticas de saída que são aplicável a janelas de instantâneo. A política de saída da janela descreve como o mecanismo CEP modifica o carimbo de data/hora de eventos que resultam de uma operação baseada em janela.
Classe pública WindowInputPolicy A política de entrada de janela descreve como os carimbos de data/hora de eventos que se encaixam em uma determinada janela são alterados antes do processamento da operação de janela.

Estruturas

  Estrutura Descrição
Estrutura pública KeyedPayload< (Of < ( <'TKey, TPayload> ) > ) >

Interfaces

  Interface Descrição
Interface pública ICepEnumerable< (Of < ( <'T> ) > ) > Estende a interface IEnumerable<T> para permitir que você especifique um nome de consulta e uma descrição para uma origem de evento enumerável.
Interface pública ICepObservable< (Of < ( <'T> ) > ) > Estende a interface IObservable<T> para permitir que você especifique um nome de consulta e uma descrição para uma origem de evento observável.
Interface pública IKey< (Of < ( <'K> ) > ) > Fornece acesso à chave de agrupamento.

Enumerações

  Enumeração Descrição
Enumeração pública WindowInputPolicy. . :: . .ClipKind O tipo de clipe para os eventos de entrada que se encaixa na mesma janela.