Classe ObservableCepStream

Oferece suporte a coletores de eventos que implementam a interface IObservable.

Hierarquia de herança

System. . :: . .Object
  Microsoft.ComplexEventProcessing.Linq..::..ObservableCepStream

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

Sintaxe

public static class ObservableCepStream

O tipo ObservableCepStream expõe os membros a seguir.

Métodos

	Nome	Descrição
	Select< (Of < <' (TInput, TOutput> ) > > )	Projeta cada evento de um fluxo de entrada observável em um novo evento.
	ToEdgeObservable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ))	Converte um CepStream de eventos de borda em um coletor de eventos que implementa a interface IObservable. A ordem dos eventos é FullyOrdered.
	ToEdgeObservable< (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 IObservable.
	ToEdgeStream< (Of < <' (TInput, TPayload> ) > > )	Converte um fluxo de entrada observável em um fluxo de eventos de borda, e fornece as características temporais da entrada.
	ToIntervalObservable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ))	Converte um CepStream de eventos de intervalo em um coletor de eventos que implementa a interface IObservable. A ordem dos eventos é FullyOrdered.
	ToIntervalObservable< (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 IObservable.
	ToIntervalStream< (Of < <' (TInput, TPayload> ) > > )	Converte um fluxo de entrada observável em um fluxo de eventos de intervalo, e fornece as características temporais da entrada.
	ToObservable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ))	Converte um fluxo de eventos em uma saída observável removendo cabeçalhos de eventos e descartando eventos CTI.
	ToObservable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), StreamEventOrder)	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.
	ToPointObservable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ))	Converte um CepStream de eventos pontuais em um coletor de eventos que implementa a interface IObservable. A ordem dos eventos é FullyOrdered.
	ToPointObservable< (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 IObservable.
	ToPointStream< (Of < <' (TInput, TPayload> ) > > )	Converte um fluxo de entrada observável em um fluxo de eventos pontuais, e fornece as características temporais da entrada.
	ToStream< (Of < <' (TPayload> ) > > )(IObservable< (Of < <' (EdgeEvent< (Of < <' (TPayload> ) > > )> ) > > ), Application, AdvanceTimeSettings, String)	Converte uma origem do evento que implementa a interface IObservable em um CepStream que pode ser consultado.
	ToStream< (Of < <' (TPayload> ) > > )(IObservable< (Of < <' (IntervalEvent< (Of < <' (TPayload> ) > > )> ) > > ), Application, AdvanceTimeSettings, String)	Converte uma origem do evento que implementa a interface IObservable em um CepStream que pode ser consultado.
	ToStream< (Of < <' (TPayload> ) > > )(IObservable< (Of < <' (PointEvent< (Of < <' (TPayload> ) > > )> ) > > ), Application, AdvanceTimeSettings, String)	Converte uma origem do evento que implementa a interface IObservable em um CepStream que pode ser consultado.
	Where< (Of < <' (TInput> ) > > )	Filtra eventos de um fluxo de entrada observável usando a expressão de filtro especificada.

Início

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