CepStream(TPayload) 类

项目
08/01/2011

表示任何用户指定的负载类型中的事件流。

继承层次结构

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

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

语法

public sealed class CepStream<TPayload>

类型参数

TPayload
流中事件的负载类型。

CepStream<(Of <(<'TPayload>)>)> 类型公开以下成员。

方法

	名称	说明
	Create(String)	使用类型为“TPayload”的事件负载创建未绑定的流。
	Create(Uri, EventShape)	从给定的已发布流对输入创建绑定流。
	Create(Uri, EventShape, AdvanceTimeSettings)	从给定的已发布流为输入创建绑定流。
	Create(Application, Uri, EventShape)	从给定的已发布流对输入创建绑定流。
	Create(String, Type, Object, EventShape)	从给定的输入适配器工厂创建绑定流。
	Create(Application, Uri, EventShape, AdvanceTimeSettings)	从给定的已发布流为输入创建绑定流。
	Create(String, Type, Object, EventShape, AdvanceTimeSettings)	从给定的输入适配器工厂创建绑定流。
	Create(Application, String, Type, Object, EventShape)	从给定的输入适配器工厂创建绑定流。
	Create(Application, String, Type, Object, EventShape, AdvanceTimeSettings)	从给定的输入适配器工厂创建绑定流。
	Equals	（从 Object 继承。）
	ExtractInputStreams	从给定的流定义中检索具有有关输入流的信息的列表。
	Finalize	（从 Object 继承。）
	GetHashCode	（从 Object 继承。）
	GetType	（从 Object 继承。）
	MemberwiseClone	（从 Object 继承。）
	ToPublishedStreamQuery(Uri, String, String, EventShape, StreamEventOrder)	创建一个查询（其输出已绑定到显式命名的已发布流）。可以通过动态查询组合来使用查询的输出。在任何给定时间，只有一个查询可以为已发布流生成事件。
	ToPublishedStreamQuery(Uri, Application, String, String, EventShape, StreamEventOrder)	创建一个查询，其中，输出已绑定到显式命名的已发布流。可以通过动态查询组合来使用查询的输出。在任何给定时间，只有一个查询可以为已发布流生成事件。
	ToQuery(String, String, EventShape, StreamEventOrder)	从带有未绑定输出的流创建查询。该查询的所有输入必须绑定到适配器、序列或其他查询。只可通过动态查询组合来使用查询的输出。将要运行此查询的应用程序由流的定义暗含。
	ToQuery(Application, String, String, EventShape, StreamEventOrder)	从流（其未绑定的输出运行于指定的应用程序中）创建查询。该查询的所有输入必须绑定到适配器、序列或其他查询。只可通过动态查询组合来使用查询的输出。
	ToQuery(String, String, Type, Object, EventShape, StreamEventOrder)	从绑定到输出适配器的流创建查询。输出适配器根据适配器工厂的类型和配置对象进行指定。将要运行此查询的应用程序由流的定义暗含。
	ToQuery(String, String, Type, Object, EventShape, StreamEventOrder, Boolean)	从绑定到输出适配器的流创建查询。输出适配器根据适配器工厂的类型和配置对象进行指定。将要运行此查询的应用程序由流的定义暗含。可以将该查询指定为有弹性的查询。
	ToQuery(Application, String, String, Type, Object, EventShape, StreamEventOrder)	从流（已绑定到指定应用程序中运行的输出适配器）创建查询。输出适配器根据适配器工厂的类型和配置对象进行指定。
	ToQuery(Application, String, String, Type, Object, EventShape, StreamEventOrder, Boolean)	从流（已绑定到指定应用程序中运行的输出适配器）创建查询。输出适配器根据适配器工厂的类型和配置对象进行指定。可以将该查询指定为有弹性的查询。
	ToString	（从 Object 继承。）

页首

扩展方法

	名称	说明
	AlterEventDuration< (Of < <' (TPayload> ) > > )	更改输入事件的持续时间。此方法不更改事件的开始时间。（由 CepStream 定义。）
	AlterEventLifetime< (Of < <' (TPayload> ) > > )	修改流中事件的生存期。此方法可能同时更改事件的开始时间和结束时间。（由 CepStream 定义。）
	ClipEventDuration< (Of < <' (TSource, TClip> ) > > )	将 sourceStream 中事件的生存期缩短至由 matchExpression 匹配的 clipStream 中下一个对应事件的开始时间。（由 CepStream 定义。）
	CountByStartTimeWindow< (Of < <' (TPayload> ) > > )(UInt32)	重载。基于给定的唯一事件开始时间数量，使用默认输出策略将输入流事件分组为事件的窗口。当在不同时间开始的新事件到达时，此窗口将偏移。（由 CepStream 定义。）
	CountByStartTimeWindow< (Of < <' (TPayload> ) > > )(UInt32, CountWindowOutputPolicy)	重载。基于给定的唯一事件开始时间数量，将输入流时间分组为事件的窗口。当在不同时间开始的新事件到达时，此窗口将偏移。（由 CepStream 定义。）
	CountByStartTimeWindow< (Of < <' (TPayload> ) > > )(UInt32, WindowInputPolicy, CountWindowOutputPolicy)	重载。基于给定的唯一事件开始时间数量，将输入流事件分组为事件的窗口。当在不同时间开始的新事件到达时，此窗口将偏移。（由 CepStream 定义。）
	GroupBy< (Of < <' (TPayload, TGroupingKey> ) > > )(Expression< (Of < <' (Func< (Of < <' (TPayload, TGroupingKey> ) > > )> ) > > ))	重载。按照指定的分组键对输入流进行分区。（由 CepStream 定义。）
	GroupBy< (Of < <' (TPayload, TGroupingKey, TResult> ) > > )(Expression< (Of < <' (Func< (Of < <' (TPayload, TGroupingKey> ) > > )> ) > > ), Expression< (Of < <' (Func< (Of < <' (TPayload, TResult> ) > > )> ) > > ))	重载。根据指定的键选择器函数对源流分组，并使用元素选择器函数对结果投影。（由 CepStream 定义。）
	HoppingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, TimeSpan)	重载。使用默认输出策略将流转换为窗口流，在该窗口流中，每个成员均为 CepWindow。此窗口根据恒定的窗口大小和跳跃大小时间跨度进行定义。（由 CepStream 定义。）
	HoppingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, TimeSpan, DateTime)	重载。使用默认输出策略将流转换为窗口流，在该窗口流中，每个成员均为 CepWindow。此窗口根据恒定的窗口大小和跳跃大小时间跨度进行定义。还可以提供对齐时间，作为窗口起点的参考。（由 CepStream 定义。）
	HoppingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, TimeSpan, HoppingWindowOutputPolicy)	重载。将流转换为窗口流，其中，每个成员均为 CepWindow。此窗口根据恒定的窗口大小和跳跃大小时间跨度进行定义。（由 CepStream 定义。）
	HoppingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, TimeSpan, DateTime, HoppingWindowOutputPolicy)	重载。将流转换为窗口流，其中，每个成员均为 CepWindow。此窗口根据不变的窗口大小和跳跃大小时间跨度进行定义。还可以提供对齐时间，作为窗口起点的参考。（由 CepStream 定义。）
	HoppingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, TimeSpan, WindowInputPolicy, HoppingWindowOutputPolicy)	重载。将流转换为窗口流，其中，每个成员均为 CepWindow。此窗口根据恒定的窗口大小和跳跃大小时间跨度进行定义。还可以提供对齐时间，作为窗口起点的参考。（由 CepStream 定义。）
	HoppingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, TimeSpan, DateTime, WindowInputPolicy, HoppingWindowOutputPolicy)	重载。此窗口根据恒定的窗口大小和跳跃大小时间跨度进行定义。还可以提供对齐时间，作为窗口起点的参考。（由 CepStream 定义。）
	IsEmpty< (Of < <' (TPayload> ) > > )	在查询中用于指示左反半部联接 (LASJ) 的函数。（由 CepStream 定义。）
	Join< (Of < <' (TOuter, TInner, TKey, TResult> ) > > )	根据给定的联接键，将来自外部流的事件与来自内部流的事件相联接。（由 CepStream 定义。）
	Select< (Of < <' (TPayload, TResult> ) > > )	使用投影表达式投影输入流中的事件。（由 CepStream 定义。）
	SelectMany< (Of < <' (TInput, TBind, TResult> ) > > )	生成基于两个输入流的交叉联接的流。（由 CepStream 定义。）
	ShiftEventTime< (Of < <' (TPayload> ) > > )(Expression< (Of < <' (Func< (Of < <' (CepEvent, DateTime> ) > > )> ) > > ))	重载。将事件的开始时间调整为新时间戳而不更改生存期。（由 CepStream 定义。）
	ShiftEventTime< (Of < <' (TPayload> ) > > )(Expression< (Of < <' (Func< (Of < <' (CepEvent, TimeSpan> ) > > )> ) > > ))	重载。根据指定的时间跨度调整事件的开始时间而不更改生存期。（由 CepStream 定义。）
	SnapshotWindow< (Of < <' (TPayload> ) > > )() () () ()	重载。使用默认输出策略将流转换为窗口流，在该窗口流中，每个成员均为 CepWindow。每个窗口都是由流中最近的事件端点定义的快照窗口。（由 CepStream 定义。）
	SnapshotWindow< (Of < <' (TPayload> ) > > )(SnapshotWindowOutputPolicy)	重载。将流转换为窗口流，其中，每个成员均为 CepWindow。每个窗口都是由流中最近的事件端点定义的快照窗口。（由 CepStream 定义。）
	SnapshotWindow< (Of < <' (TPayload> ) > > )(WindowInputPolicy, SnapshotWindowOutputPolicy)	重载。将流转换为窗口流，其中，每个成员均为 CepWindow。每个窗口都是由流中最近的事件端点定义的快照窗口。（由 CepStream 定义。）
	ToEdgeEnumerable< (Of < <' (TPayload> ) > > )() () () ()	重载。将边缘事件的 CepStream 转换为用于实现 IEnumerable 接口的事件接收器。事件的顺序为 FullyOrdered。（由 CepStream 定义。）
	ToEdgeEnumerable< (Of < <' (TPayload> ) > > )(StreamEventOrder)	重载。将具有指定事件顺序的边缘事件的 CepStream 转换为用于实现 IEnumerable 接口的事件接收器。（由 CepStream 定义。）
	ToEdgeObservable< (Of < <' (TPayload> ) > > )() () () ()	重载。将边缘事件的 CepStream 转换为用于实现 IObservable 接口的事件接收器。事件的顺序为 FullyOrdered。（由 ObservableCepStream 定义。）
	ToEdgeObservable< (Of < <' (TPayload> ) > > )(StreamEventOrder)	重载。将具有指定事件顺序的边缘事件的 CepStream 转换为用于实现 IObservable 接口的事件接收器。（由 ObservableCepStream 定义。）
	ToEnumerable< (Of < <' (TPayload> ) > > )() () () ()	重载。通过删除事件标头和舍弃 CTI 事件，将事件流转换为可枚举的输出。（由 CepStream 定义。）
	ToEnumerable< (Of < <' (TPayload> ) > > )(StreamEventOrder)	重载。通过删除事件标头和舍弃 CTI 事件，将事件流转换为具有指定事件顺序的可枚举输出。（由 CepStream 定义。）
	ToIntervalEnumerable< (Of < <' (TPayload> ) > > )() () () ()	重载。将间隔事件的 CepStream 转换为用于实现 IEnumerable 接口的事件接收器。事件的顺序为 FullyOrdered。（由 CepStream 定义。）
	ToIntervalEnumerable< (Of < <' (TPayload> ) > > )(StreamEventOrder)	重载。将具有指定事件顺序的间隔事件的 CepStream 转换为用于实现 IEnumerable 接口的事件接收器。（由 CepStream 定义。）
	ToIntervalObservable< (Of < <' (TPayload> ) > > )() () () ()	重载。将间隔事件的 CepStream 转换为用于实现 IObservable 接口的事件接收器。事件的顺序为 FullyOrdered。（由 ObservableCepStream 定义。）
	ToIntervalObservable< (Of < <' (TPayload> ) > > )(StreamEventOrder)	重载。将具有指定事件顺序的间隔事件的 CepStream 转换为用于实现 IObservable 接口的事件接收器。（由 ObservableCepStream 定义。）
	ToObservable< (Of < <' (TPayload> ) > > )() () () ()	重载。通过删除事件标头和舍弃 CTI 事件，将事件流转换为可观察的输出。（由 ObservableCepStream 定义。）
	ToObservable< (Of < <' (TPayload> ) > > )(StreamEventOrder)	重载。通过删除事件标头和舍弃 CTI 事件，将事件流转换为具有指定事件顺序的可观察输出。（由 ObservableCepStream 定义。）
	ToPointEnumerable< (Of < <' (TPayload> ) > > )() () () ()	重载。将点事件的 CepStream 转换为用于实现 IEnumerable 接口的事件接收器。事件的顺序为 FullyOrdered。（由 CepStream 定义。）
	ToPointEnumerable< (Of < <' (TPayload> ) > > )(StreamEventOrder)	重载。将具有指定事件顺序的点事件的 CepStream 转换为用于实现 IEnumerable 接口的事件接收器。（由 CepStream 定义。）
	ToPointEventStream< (Of < <' (TPayload> ) > > )	通过只保留事件开始时间，将输入流中的事件更改为点事件。（由 CepStream 定义。）
	ToPointObservable< (Of < <' (TPayload> ) > > )() () () ()	重载。将点事件的 CepStream 转换为用于实现 IObservable 接口的事件接收器。事件的顺序为 FullyOrdered。（由 ObservableCepStream 定义。）
	ToPointObservable< (Of < <' (TPayload> ) > > )(StreamEventOrder)	重载。将具有指定事件顺序的点事件的 CepStream 转换为用于实现 IObservable 接口的事件接收器。（由 ObservableCepStream 定义。）
	TumblingWindow< (Of < <' (TPayload> ) > > )(TimeSpan)	重载。使用默认输出策略将流转换为窗口流，在该窗口流中，每个成员均为 CepWindow。翻转窗口是一种特殊的跳跃窗口，其中，窗口大小和跳跃大小相同。（由 CepStream 定义。）
	TumblingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, DateTime)	重载。使用默认输出策略将流转换为窗口流，在该窗口流中，每个成员均为 CepWindow。翻转窗口是一种特殊的跳跃窗口，其中，窗口大小和跳跃大小相同。还可以提供对齐时间，作为窗口起点的参考。（由 CepStream 定义。）
	TumblingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, HoppingWindowOutputPolicy)	重载。将流转换为窗口流，其中，每个成员均为 CepWindow。翻转窗口是一种特殊的跳跃窗口，其中，窗口大小和跳跃大小相同。（由 CepStream 定义。）
	TumblingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, DateTime, HoppingWindowOutputPolicy)	重载。将流转换为窗口流，其中，每个成员均为 CepWindow。翻转窗口是一种特殊的跳跃窗口，其中，窗口大小和跳跃大小相同。还可以提供对齐时间，作为窗口起点的参考。（由 CepStream 定义。）
	TumblingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, WindowInputPolicy, HoppingWindowOutputPolicy)	重载。将流转换为窗口流，其中，每个成员均为 CepWindow。翻转窗口是一种特殊的跳跃窗口，其中，窗口大小和跳跃大小相同。还可以提供对齐时间，作为窗口起点的参考。（由 CepStream 定义。）
	TumblingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, DateTime, WindowInputPolicy, HoppingWindowOutputPolicy)	重载。将流转换为窗口流，其中，每个成员均为 CepWindow。翻转窗口是一种特殊的跳跃窗口，其中，窗口大小和跳跃大小相同。还可以提供对齐时间，作为窗口起点的参考。（由 CepStream 定义。）
	Union< (Of < <' (TPayload> ) > > )	将两个流联合成一个流。（由 CepStream 定义。）
	Where< (Of < <' (TPayload> ) > > )	使用给定的筛选器函数筛选输入流中的事件。（由 CepStream 定义。）

页首

注释

在编写 CEP 查询前，必须提供相应的流定义。此类提供各种方法来创建 CepStream 对象。

线程安全

此类型的任何公共 static（在 Visual Basic 中为 Shared）成员都是线程安全的。不保证所有实例成员都是线程安全的。

请参阅

参考

Microsoft.ComplexEventProcessing.Linq 命名空间

通过

CepStream(TPayload) 类

继承层次结构

语法

类型参数

方法

扩展方法

注释

线程安全

请参阅

参考

其他资源