ObservableCepStream 类

项目
08/01/2011

为实现 IObservable 接口的事件接收器提供支持。

继承层次结构

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

命名空间： Microsoft.ComplexEventProcessing.Linq
程序集： Microsoft.ComplexEventProcessing.Observable（在 Microsoft.ComplexEventProcessing.Observable.dll 中）

语法

public static class ObservableCepStream

ObservableCepStream 类型公开以下成员。

方法

	名称	说明
	Select< (Of < <' (TInput, TOutput> ) > > )	将可观察输入流的每个事件投影到新事件。
	ToEdgeObservable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ))	将边缘事件的 CepStream 转换为用于实现 IObservable 接口的事件接收器。事件的顺序为 FullyOrdered。
	ToEdgeObservable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), StreamEventOrder)	将具有指定事件顺序的边缘事件的 CepStream 转换为用于实现 IObservable 接口的事件接收器。
	ToEdgeStream< (Of < <' (TInput, TPayload> ) > > )	将可观察的输入流转换为边缘事件流，并提供输入的临时特征。
	ToIntervalObservable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ))	将间隔事件的 CepStream 转换为用于实现 IObservable 接口的事件接收器。事件的顺序为 FullyOrdered。
	ToIntervalObservable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), StreamEventOrder)	将具有指定事件顺序的间隔事件的 CepStream 转换为用于实现 IObservable 接口的事件接收器。
	ToIntervalStream< (Of < <' (TInput, TPayload> ) > > )	将可观察的输入流转换为间隔事件流，并提供输入的临时特征。
	ToObservable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ))	通过删除事件标头和舍弃 CTI 事件，将事件流转换为可观察的输出。
	ToObservable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), StreamEventOrder)	通过删除事件标头和舍弃 CTI 事件，将事件流转换为具有指定事件顺序的可观察输出。
	ToPointObservable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ))	将点事件的 CepStream 转换为用于实现 IObservable 接口的事件接收器。事件的顺序为 FullyOrdered。
	ToPointObservable< (Of < <' (TPayload> ) > > )(CepStream< (Of < <' (TPayload> ) > > ), StreamEventOrder)	将具有指定事件顺序的点事件的 CepStream 转换为用于实现 IObservable 接口的事件接收器。
	ToPointStream< (Of < <' (TInput, TPayload> ) > > )	将可观察的输入流转换为点事件流，并提供输入的临时特征。
	ToStream< (Of < <' (TPayload> ) > > )(IObservable< (Of < <' (EdgeEvent< (Of < <' (TPayload> ) > > )> ) > > ), Application, AdvanceTimeSettings, String)	将实现 IObservable 接口的事件源转换为可以进行查询的 CepStream。
	ToStream< (Of < <' (TPayload> ) > > )(IObservable< (Of < <' (IntervalEvent< (Of < <' (TPayload> ) > > )> ) > > ), Application, AdvanceTimeSettings, String)	将实现 IObservable 接口的事件源转换为可以进行查询的 CepStream。
	ToStream< (Of < <' (TPayload> ) > > )(IObservable< (Of < <' (PointEvent< (Of < <' (TPayload> ) > > )> ) > > ), Application, AdvanceTimeSettings, String)	将实现 IObservable 接口的事件源转换为可以进行查询的 CepStream。
	Where< (Of < <' (TInput> ) > > )	使用指定的筛选表达式筛选可观察输入流中的事件。