HoppingWindow(TPayload) 方法 (CepStream(TPayload), TimeSpan, TimeSpan, WindowInputPolicy, HoppingWindowOutputPolicy)

将流转换为窗口流，其中，每个成员均为 CepWindow。此窗口根据恒定的窗口大小和跳跃大小时间跨度进行定义。还可以提供对齐时间，作为窗口起点的参考。

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

语法

public static CepWindowStream<CepWindow<TPayload>> HoppingWindow<TPayload>(
    this CepStream<TPayload> source,
    TimeSpan windowSize,
    TimeSpan hopSize,
    WindowInputPolicy inputPolicy,
    HoppingWindowOutputPolicy outputPolicy
)

类型参数

• TPayload
  输入事件负载的类型。

参数

• source
  类型：Microsoft.ComplexEventProcessing.Linq. . :: . .CepStream< (Of < ( <'TPayload> ) > ) >
  要对其应用 HoppingWindow 操作的 CepStream。

• windowSize
  类型：System. . :: . .TimeSpan
  窗口的长度。

• hopSize
  类型：System. . :: . .TimeSpan
  窗口的跳跃大小。

• inputPolicy
  类型：Microsoft.ComplexEventProcessing.Linq. . :: . .WindowInputPolicy
  指示在输入到窗口操作中之前如何更改事件。

• outputPolicy
  类型：Microsoft.ComplexEventProcessing.Linq. . :: . .HoppingWindowOutputPolicy
  指示在引入回流中之前如何更改窗口操作的输出事件。

返回值

类型：Microsoft.ComplexEventProcessing.Linq. . :: . .CepWindowStream< (Of < ( <'CepWindow< (Of < ( <'TPayload> ) > ) >> ) > ) >
聚合、TopK 或用户定义的运算符 (UDO) 可应用于的窗口流。

用法说明

在 Visual Basic 和 C# 中，您可以对 CepStream< (Of < ( <'TPayload> ) > ) > 类型的任何对象将此方法作为实例方法调用。在您使用实例方法语法调用此方法时，将忽略第一个参数。有关详细信息，请参阅https://msdn.microsoft.com/zh-cn/library/bb384936(v=sql.105)或https://msdn.microsoft.com/zh-cn/library/bb383977(v=sql.105)。

注释

有关详细信息，请参阅使用事件窗口。

请参阅

参考

CepStream 类

HoppingWindow 重载

Microsoft.ComplexEventProcessing.Linq 命名空间