CepStream.ToIntervalStream<TInput, TPayload> 方法 (IEnumerable<TInput>, Application, Expression<Func<TInput, IntervalEvent<TPayload>>>, AdvanceTimeSettings, String)

 

將可列舉輸入資料流轉換為間隔事件資料流,並提供暫時的輸入特性。

命名空間:   Microsoft.ComplexEventProcessing.Linq
組件:  Microsoft.ComplexEventProcessing (在 Microsoft.ComplexEventProcessing.dll 中)

語法

public static CepStream<TPayload> ToIntervalStream<TInput, TPayload>(
    this IEnumerable<TInput> source,
    Application application,
    Expression<Func<TInput, IntervalEvent<TPayload>>> selector,
    AdvanceTimeSettings advanceTimeSettings = null,
    string streamName = null
)
public:
generic<typename TInput, typename TPayload>
[ExtensionAttribute]
static CepStream<TPayload>^ ToIntervalStream(
    IEnumerable<TInput>^ source,
    Application^ application,
    Expression<Func<TInput, IntervalEvent<TPayload>^>^>^ selector,
    AdvanceTimeSettings^ advanceTimeSettings = null,
    String^ streamName = null
)
static member ToIntervalStream<'TInput, 'TPayload> : 
        source:IEnumerable<'TInput> *
        application:Application *
        selector:Expression<Func<'TInput, IntervalEvent<'TPayload>>> *
        advanceTimeSettings:AdvanceTimeSettings = null *
        streamName:string = null -> CepStream<'TPayload>
<ExtensionAttribute>
Public Shared Function ToIntervalStream(Of TInput, TPayload) (
    source As IEnumerable(Of TInput),
    application As Application,
    selector As Expression(Of Func(Of TInput, IntervalEvent(Of TPayload))),
    advanceTimeSettings As AdvanceTimeSettings,
    streamName As String
) As CepStream(Of TPayload)

參數

  • source
    可列舉輸入資料流。
  • application
    主控事件來源的應用程式執行個體。
  • selector
    將輸入的外觀重新安排為間隔事件資料流的運算式。
  • advanceTimeSettings
    輸入的暫時特性。
  • streamName
    資料流名稱支援使用 AdvanceTimeImportSettings 在資料流之間「匯入」CTI 事件。

傳回值

Type: Microsoft.ComplexEventProcessing.Linq.CepStream<TPayload>

間隔事件的資料流。

類型參數

  • TInput
    輸入的類型。
  • TPayload
    事件裝載的類型。

請參閱

CepStream 類別
Microsoft.ComplexEventProcessing.Linq 命名空間

回到頁首