ToIntervalStream(TInput, TPayload) 方法

将可观察的输入流转换为间隔事件流，并提供输入的临时特征。

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

语法

public static CepStream<TPayload> ToIntervalStream<TInput, TPayload>(
    this IObservable<TInput> source,
    Application application,
    Expression<Func<TInput, IntervalEvent<TPayload>>> selector,
    AdvanceTimeSettings advanceTimeSettings,
    string streamName
)

类型参数

• TInput
  输入的类型。

• TPayload
  事件负载的类型。

参数

• source
  类型：System. . :: . .IObservable< (Of < ( <'TInput> ) > ) >
  可观察的输入流。

• application
  类型：Microsoft.ComplexEventProcessing. . :: . .Application
  承载事件源的应用程序实例。此参数不能为 Null。应用程序必须属于某个嵌入式服务器，而该服务器是通过调用 Server.Create 的重载之一生成的。

• selector
  类型：System.Linq.Expressions. . :: . .Expression< (Of < ( <'Func< (Of < ( <'TInput, IntervalEvent< (Of < ( <'TPayload> ) > ) >> ) > ) >> ) > ) >
  将输入重新定形为间隔事件流的表达式。

• advanceTimeSettings
  类型：Microsoft.ComplexEventProcessing. . :: . .AdvanceTimeSettings
  输入的临时特征。

• streamName
  类型：System. . :: . .String
  流的名称。
  流名称支持使用 AdvanceTimeImportSettings 将 CTI 事件从一个流“导入”另一个流。这些设置要求用户指出从中导入 CTI 事件的输入流的名称。

返回值

类型：Microsoft.ComplexEventProcessing.Linq. . :: . .CepStream< (Of < ( <'TPayload> ) > ) >
间隔事件的流。

用法说明

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

请参阅

参考

ObservableCepStream 类

Microsoft.ComplexEventProcessing.Linq 命名空间