共用方式為


IStreamable<TKey,TPayload> 介面

定義

可串流作業的主要介面 - 使用者不應該建立實作此介面的新類別,而不需與開發小組直接通訊

public interface IStreamable<TKey,TPayload>
type IStreamable<'Key, 'Payload> = interface
Public Interface IStreamable(Of TKey, TPayload)

類型參數

TKey

將串流資料的索引鍵類型分組

TPayload

串流資料的事件承載類型

衍生

屬性

ErrorMessages

傳回程序代碼產生期間遇到的任何錯誤。

Properties

傳回資料流程的目前屬性,例如資料流程是否為常數持續時間資料流程。

方法

Subscribe(IStreamObserver<TKey,TPayload>)

立即開始將事件從資料流程傳送至觀察者。

擴充方法

GetProperties<TKey,TPayload>(IStreamable<TKey,TPayload>, StreamProperties<TKey,TPayload>)

將 out 參數 (屬性) 設定為數據流的目前屬性

SetProperties<TKey,TPayload>(IStreamable<TKey,TPayload>, StreamProperties<TKey,TPayload>)

將目前的資料流程屬性設定為所提供引數, (newProperties)

SetProperty<TKey,TPayload>(IStreamable<TKey,TPayload>)

進入模式,您可以在其中設定資料流程的屬性。

Aggregate<TKey,TInput,TState1,TOutput1,TState2,TOutput2,TState3, TOutput3,TState4,TOutput4,TOutput>(IStreamable<TKey,TInput>, Func<Window<TKey, TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState4,TOutput4>>, Expression<Func<TOutput1, TOutput2,TOutput3,TOutput4,TOutput>>)

將多個匯總套用至輸入資料流程上的快照集視窗。

Aggregate<TKey,TInput,TState1,TOutput1,TState2,TOutput2,TState3, TOutput3,TState4,TOutput4,TState5,TOutput5,TOutput>(IStreamable<TKey, TInput>, Func<Window<TKey,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState5,TOutput5>>, Expression<Func<TOutput1,TOutput2,TOutput3,TOutput4,TOutput5, TOutput>>)

將多個匯總套用至輸入資料流程上的快照集視窗。

Aggregate<TKey,TInput,TState1,TOutput1,TState2,TOutput2,TState3, TOutput3,TState4,TOutput4,TState5,TOutput5,TState6,TOutput6,TOutput>(IStreamable<TKey, TInput>, Func<Window<TKey,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState6,TOutput6>>, Expression<Func<TOutput1,TOutput2,TOutput3,TOutput4,TOutput5, TOutput6,TOutput>>)

將多個匯總套用至輸入資料流程上的快照集視窗。

Aggregate<TKey,TInput,TState1,TOutput1,TState2,TOutput2,TState3, TOutput3,TState4,TOutput4,TState5,TOutput5,TState6,TOutput6,TState7, TOutput7,TOutput>(IStreamable<TKey,TInput>, Func<Window<TKey, TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState7,TOutput7>>, Expression<Func<TOutput1, TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7,TOutput>>)

將多個匯總套用至輸入資料流程上的快照集視窗。

Aggregate<TKey,TInput,TState1,TOutput1,TState2,TOutput2,TState3, TOutput3,TState4,TOutput4,TState5,TOutput5,TState6,TOutput6,TState7, TOutput7,TState8,TOutput8,TOutput>(IStreamable<TKey,TInput>, Func<Window<TKey, TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState8,TOutput8>>, Expression<Func<TOutput1, TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7,TOutput8, TOutput>>)

將多個匯總套用至輸入資料流程上的快照集視窗。

Aggregate<TKey,TInput,TState1,TOutput1,TState2,TOutput2,TState3, TOutput3,TState4,TOutput4,TState5,TOutput5,TState6,TOutput6,TState7, TOutput7,TState8,TOutput8,TState9,TOutput9,TOutput>(IStreamable<TKey, TInput>, Func<Window<TKey,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState8,TOutput8>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState9,TOutput9>>, Expression<Func<TOutput1,TOutput2,TOutput3,TOutput4,TOutput5, TOutput6,TOutput7,TOutput8,TOutput9,TOutput>>)

將多個匯總套用至輸入資料流程上的快照集視窗。

Aggregate<TKey,TInput,TState1,TOutput1,TState2,TOutput2,TState3, TOutput3,TState4,TOutput4,TState5,TOutput5,TState6,TOutput6,TState7, TOutput7,TState8,TOutput8,TState9,TOutput9,TState10,TOutput10, TOutput>(IStreamable<TKey,TInput>, Func<Window<TKey,TInput>,IAggregate<TInput, TState1,TOutput1>>, Func<Window<TKey,TInput>,IAggregate<TInput, TState2,TOutput2>>, Func<Window<TKey,TInput>,IAggregate<TInput, TState3,TOutput3>>, Func<Window<TKey,TInput>,IAggregate<TInput, TState4,TOutput4>>, Func<Window<TKey,TInput>,IAggregate<TInput, TState5,TOutput5>>, Func<Window<TKey,TInput>,IAggregate<TInput, TState6,TOutput6>>, Func<Window<TKey,TInput>,IAggregate<TInput, TState7,TOutput7>>, Func<Window<TKey,TInput>,IAggregate<TInput, TState8,TOutput8>>, Func<Window<TKey,TInput>,IAggregate<TInput, TState9,TOutput9>>, Func<Window<TKey,TInput>,IAggregate<TInput, TState10,TOutput10>>, Expression<Func<TOutput1,TOutput2,TOutput3, TOutput4,TOutput5,TOutput6,TOutput7,TOutput8,TOutput9,TOutput10, TOutput>>)

將多個匯總套用至輸入資料流程上的快照集視窗。

Aggregate<TKey,TInput,TState1,TOutput1,TState2,TOutput2,TState3, TOutput3,TState4,TOutput4,TState5,TOutput5,TState6,TOutput6,TState7, TOutput7,TState8,TOutput8,TState9,TOutput9,TState10,TOutput10, TState11,TOutput11,TOutput>(IStreamable<TKey,TInput>, Func<Window<TKey, TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState8,TOutput8>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState9,TOutput9>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState10,TOutput10>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState11,TOutput11>>, Expression<Func<TOutput1, TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7,TOutput8, TOutput9,TOutput10,TOutput11,TOutput>>)

將多個匯總套用至輸入資料流程上的快照集視窗。

Aggregate<TKey,TInput,TState1,TOutput1,TState2,TOutput2,TState3, TOutput3,TState4,TOutput4,TState5,TOutput5,TState6,TOutput6,TState7, TOutput7,TState8,TOutput8,TState9,TOutput9,TState10,TOutput10, TState11,TOutput11,TState12,TOutput12,TOutput>(IStreamable<TKey, TInput>, Func<Window<TKey,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState8,TOutput8>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState9,TOutput9>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState10,TOutput10>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState11,TOutput11>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState12,TOutput12>>, Expression<Func<TOutput1,TOutput2,TOutput3,TOutput4,TOutput5, TOutput6,TOutput7,TOutput8,TOutput9,TOutput10,TOutput11,TOutput12, TOutput>>)

將多個匯總套用至輸入資料流程上的快照集視窗。

Aggregate<TKey,TInput,TState1,TOutput1,TState2,TOutput2,TState3, TOutput3,TState4,TOutput4,TState5,TOutput5,TState6,TOutput6,TState7, TOutput7,TState8,TOutput8,TState9,TOutput9,TState10,TOutput10, TState11,TOutput11,TState12,TOutput12,TState13,TOutput13,TOutput>(IStreamable<TKey, TInput>, Func<Window<TKey,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState8,TOutput8>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState9,TOutput9>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState10,TOutput10>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState11,TOutput11>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState12,TOutput12>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState13,TOutput13>>, Expression<Func<TOutput1,TOutput2,TOutput3,TOutput4,TOutput5, TOutput6,TOutput7,TOutput8,TOutput9,TOutput10,TOutput11,TOutput12, TOutput13,TOutput>>)

將多個匯總套用至輸入資料流程上的快照集視窗。

Aggregate<TKey,TInput,TState1,TOutput1,TState2,TOutput2,TState3, TOutput3,TState4,TOutput4,TState5,TOutput5,TState6,TOutput6,TState7, TOutput7,TState8,TOutput8,TState9,TOutput9,TState10,TOutput10, TState11,TOutput11,TState12,TOutput12,TState13,TOutput13,TState14, TOutput14,TOutput>(IStreamable<TKey,TInput>, Func<Window<TKey, TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState8,TOutput8>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState9,TOutput9>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState10,TOutput10>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState11,TOutput11>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState12,TOutput12>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState13,TOutput13>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState14,TOutput14>>, Expression<Func<TOutput1, TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7,TOutput8, TOutput9,TOutput10,TOutput11,TOutput12,TOutput13,TOutput14,TOutput>>)

將多個匯總套用至輸入資料流程上的快照集視窗。

Aggregate<TKey,TInput,TState1,TOutput1,TState2,TOutput2,TState3, TOutput3,TState4,TOutput4,TState5,TOutput5,TState6,TOutput6,TState7, TOutput7,TState8,TOutput8,TState9,TOutput9,TState10,TOutput10, TState11,TOutput11,TState12,TOutput12,TState13,TOutput13,TState14, TOutput14,TState15,TOutput15,TOutput>(IStreamable<TKey,TInput>, Func<Window<TKey,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState8,TOutput8>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState9,TOutput9>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState10,TOutput10>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState11,TOutput11>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState12,TOutput12>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState13,TOutput13>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState14,TOutput14>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState15,TOutput15>>, Expression<Func<TOutput1,TOutput2,TOutput3,TOutput4,TOutput5, TOutput6,TOutput7,TOutput8,TOutput9,TOutput10,TOutput11,TOutput12, TOutput13,TOutput14,TOutput15,TOutput>>)

將多個匯總套用至輸入資料流程上的快照集視窗。

Aggregate<TKey,TInput,TState,TOutput>(IStreamable<TKey,TInput>, Func<Window<TKey,TInput>,IAggregate<TInput,TState,TOutput>>)

將匯總套用至輸入資料流程上的快照集視窗。

Aggregate<TKey,TInput,TState1,TOutput1,TState2,TOutput2,TOutput>(IStreamable<TKey, TInput>, Func<Window<TKey,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<TKey,TInput>,IAggregate<TInput,TState2,TOutput2>>, Expression<Func<TOutput1,TOutput2,TOutput>>)

將多個匯總套用至輸入資料流程上的快照集視窗。

Aggregate<TKey,TInput,TState1,TOutput1,TState2,TOutput2,TState3, TOutput3,TOutput>(IStreamable<TKey,TInput>, Func<Window<TKey, TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<TKey, TInput>,IAggregate<TInput,TState3,TOutput3>>, Expression<Func<TOutput1, TOutput2,TOutput3,TOutput>>)

將多個匯總套用至輸入資料流程上的快照集視窗。

AlterEventDuration<TKey,TPayload>(IStreamable<TKey,TPayload>, Int64)

根據提供的持續時間變更每個事件的 Ve

AlterEventDuration<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<Int64,Int64,Int64>>)

根據 durationSelector 變更每個事件的 Ve,這是開始和結束時間的函式

AlterEventDuration<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<Int64,Int64>>)

根據 durationSelector 變更每個事件的 Ve,這是開始時間的函式

AlterEventLifetime<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<Int64,Int64>>, Int64)

變更每個事件的 Vs 和 Ve。

AlterEventLifetime<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<Int64,Int64>>, Expression<Func<Int64,Int64,Int64>>)

根據 startTimeSelector 變更每個事件的 Vs 和 Ve,以及 durationSelector,這是開始和結束時間的函式

AlterEventLifetime<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<Int64,Int64>>, Expression<Func<Int64,Int64>>)

根據 startTimeSelector 變更每個事件的 Vs 和 Ve,以及 durationSelector,這是開始時間的函式

Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Byte>>)

使用「快照集視窗」 (SI 術語) ,計算位元組的區分時間平均匯總。 請注意,累積器在內部是 ulong 資料類型。

Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Decimal>>)

使用「快照集視窗」 (SI 術語) ,計算小數點的時間敏感性平均匯總。 請注意,累積器在內部是十進位資料類型。

Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Double>>)

使用「快照集視窗」 (SI 術語) ,計算兩倍的時間敏感平均匯總。 請注意,累積器在內部是雙資料類型。

Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int16>>)

使用「快照集視窗」 (SI 術語) ,計算短時間平均匯總。 請注意,累積器在內部是長資料類型。

Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int32>>)

使用「快照集視窗」 (SI 術語) ,計算對 int 的時間敏感平均匯總。 請注意,累積器在內部是長資料類型。

Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int64>>)

使用「快照集視窗」 (SI 術語) ,計算長時間的時間敏感平均匯總。 請注意,累積器在內部是長資料類型。

Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Byte>>>)

使用「快照集視窗」 (SI 術語) 計算可 Null 位元組的時間敏感性平均匯總。 請注意,累積器在內部是 ulong 資料類型,而且 Null 對平均值沒有任何影響。

Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Decimal>>>)

使用「快照集視窗」 (SI 術語) 計算可 Null 小數點的時間敏感性平均匯總。 請注意,累積器在內部是十進位資料類型,而且 Null 對平均值沒有任何影響。

Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Double>>>)

使用「快照集視窗」 (SI 術語) 計算可 Null 雙精度浮點數的時效平均匯總。 請注意,累積器在內部是雙精度浮點數,而且 Null 對平均值沒有任何影響。

Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int16>>>)

使用「快照集視窗」 (SI 術語) ,透過可為 Null 的簡短計算時間敏感平均匯總。 請注意,累積器在內部是長資料類型,而且 Null 對平均值沒有任何影響。

Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int32>>>)

使用「快照集視窗」 (SI 術語) ,以時間敏感度平均計算可為 Null 的 int 匯總。 請注意,累積器在內部是長資料類型,而且 Null 對平均值沒有任何影響。

Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int64>>>)

使用「快照集視窗」 (SI 術語) ,在可為 Null 的長期間計算時間敏感平均匯總。 請注意,累積器在內部是長資料類型,而且 Null 對平均值沒有任何影響。

Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<BigInteger>>>)

使用「快照集視窗」 (SI 術語) ,計算可為 Null BigIntegers 的時間敏感平均匯總。 請注意,累積器在內部是 BigInteger 資料類型,而且 Null 對平均值沒有任何影響。

Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Complex>>>)

使用「快照集視窗」 (SI 術語) ,針對可為 Null 的複雜數計算時間敏感平均匯總。 請注意,累積器在內部是複雜資料類型,而且 Null 對平均值沒有任何影響。

Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<SByte>>>)

使用「snapshot windows」 (SI 術語,計算可針對可為 Null 的 sbytes 進行時間敏感平均匯總) 。 請注意,累積器在內部是長資料類型,而且 Null 對平均值沒有任何影響。

Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Single>>>)

使用「快照集視窗」 (SI 術語) ,計算可為 Null 浮點數的時間敏感性平均匯總。 請注意,累積器在內部是 float 資料類型,而且 Null 對平均值沒有任何影響。

Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt16>>>)

使用「快照集視窗」 (SI 術語) ,針對可為 Null 的 ushorts 計算時間敏感平均匯總。 請注意,累積器在內部是 ulong 資料類型,而且 Null 對平均值沒有任何影響。

Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt32>>>)

使用「快照集視窗」 (SI 術語) ,計算可 null 平均匯總。 請注意,累積器在內部是 ulong 資料類型,而且 Null 對平均值沒有任何影響。

Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt64>>>)

使用「快照集視窗」 (SI 術語) ,在可為 Null 的 ulong 上計算時間敏感平均匯總。 請注意,累積器在內部是 ulong 資料類型,而且 Null 對平均值沒有任何影響。

Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,BigInteger>>)

使用「快照集視窗」 (SI 術語) ,計算 BigIntegers 的時間敏感性平均匯總。 請注意,累積器在內部是 BigInteger 資料類型。

Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Complex>>)

使用「快照集視窗」 (SI 術語) 計算複雜資料的時間敏感平均匯總。 請注意,累積器在內部是複雜資料類型。

Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,SByte>>)

使用「快照集視窗」 (SI 術語) ,計算跨位元組的時間敏感平均匯總。 請注意,累積器在內部是長資料類型。

Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Single>>)

使用「快照集視窗」 (SI 術語) ,計算浮點數的時間敏感性平均匯總。 請注意,累積器在內部是 float 資料類型。

Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt16>>)

使用「快照集視窗」 (SI 術語) ,計算跨我們世代的時間敏感平均匯總。 請注意,累積器在內部是 ulong 資料類型。

Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt32>>)

使用「快照集視窗」 (SI 術語) ,計算對 uint 的時間敏感平均匯總。 請注意,累積器在內部是 ulong 資料類型。

Average<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt64>>)

使用「快照集視窗」 (SI 術語) ,計算 ulong 上的時間敏感性平均匯總。 請注意,累積器在內部是 ulong 資料類型。

AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Byte>>)

使用「快照視窗」 (SI 術語) ,計算平方在位元組上匯總的時間平均。 請注意,累積器在內部是 ulong 資料類型。

AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Decimal>>)

使用「快照集視窗」 (SI 術語,計算十進位數的平方平均) 。 請注意,累積器在內部是十進位資料類型。

AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Double>>)

使用「快照集視窗」 (SI 術語) ,計算雙精度浮點數的平方平均。 請注意,累積器在內部是雙資料類型。

AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int16>>)

使用「快照集視窗」 (SI 術語) ,計算簡短匯總的平方平均時間。 請注意,累積器在內部是長資料類型。

AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int32>>)

使用「快照視窗」 (SI 術語) ,計算平方的時效平均匯總。 請注意,累積器在內部是長資料類型。

AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int64>>)

使用「快照集視窗」 (SI 術語) ,計算長時間匯總的平方平均。 請注意,累積器在內部是長資料類型。

AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Byte>>>)

使用「snapshot windows」 (SI 術語,計算平方在可為 Null 位元組) 的時間敏感性平均值。 請注意,累積器在內部是 ulong 資料類型,而且 Null 對平均值沒有任何影響。

AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Decimal>>>)

使用「快照集視窗」 (SI 術語,計算平方在可為 Null 的十進位數上匯總的時間敏感性平均值) 。 請注意,累積器在內部是十進位資料類型,而且 Null 對平均值沒有任何影響。

AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Double>>>)

使用「snapshot windows」 (SI 術語,計算平方在可為 Null 的雙精度浮點數上匯總的時間平均) 。 請注意,累積器在內部是雙精度浮點數,而且 Null 對平均值沒有任何影響。

AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int16>>>)

使用「快照集視窗」 (SI 術語,計算平方在可為 Null 的簡短) 時間平均。 請注意,累積器在內部是長資料類型,而且 Null 對平均值沒有任何影響。

AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int32>>>)

使用「snapshot windows」 (SI 術語,計算平方在可為 Null 的方塊上匯總的時間平均) 。 請注意,累積器在內部是長資料類型,而且 Null 對平均值沒有任何影響。

AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int64>>>)

使用「snapshot windows」 (SI 術語,計算平方在可為 Null 的長期間) 的時間平均。 請注意,累積器在內部是長資料類型,而且 Null 對平均值沒有任何影響。

AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<BigInteger>>>)

使用「snapshot windows」 (SI 術語,計算可 Null BigIntegers 的平方平均) 。 請注意,累積器在內部是 BigInteger 資料類型,而且 Null 對平均值沒有任何影響。

AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Complex>>>)

使用「快照集視窗」 (SI 術語) ,計算可 Null 複本匯總的平方平均。 請注意,累積器在內部是複雜資料類型,而且 Null 對平均值沒有任何影響。

AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<SByte>>>)

使用「snapshot windows」 (SI 術語,計算可針對可為 Null sbytes 匯總的時間敏感度平均) 。 請注意,累積器在內部是長資料類型,而且 Null 對平均值沒有任何影響。

AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Single>>>)

使用「快照集視窗」 (SI 術語,計算可 Null 浮點數的平方平均) 。 請注意,累積器在內部是 float 資料類型,而且 Null 對平均值沒有任何影響。

AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt16>>>)

使用「snapshot windows」 (SI 術語,計算可針對可為 Null 之 ushorts 匯總的時間敏感性平均) 。 請注意,累積器在內部是 ulong 資料類型,而且 Null 對平均值沒有任何影響。

AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt32>>>)

使用「snapshot windows」 (SI 術語,計算可針對可為 Null 的 uint 匯總的時間敏感性平均) 。 請注意,累積器在內部是 ulong 資料類型,而且 Null 對平均值沒有任何影響。

AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt64>>>)

使用「snapshot windows」 (SI 術語) ,計算可 Null ulong 的平方匯總時間平均。 請注意,累積器在內部是 ulong 資料類型,而且 Null 對平均值沒有任何影響。

AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,BigInteger>>)

使用「snapshot windows」 (SI 術語) ,計算 BigIntegers 上匯總的時效平均。 請注意,累積器在內部是 BigInteger 資料類型。

AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Complex>>)

使用「快照集視窗」 (SI 術語) ,計算對複雜數的平方匯總時間平均。 請注意,累積器在內部是複雜資料類型。

AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,SByte>>)

使用「snapshot windows」 (SI 術語) 計算平方的時效平均。 請注意,累積器在內部是長資料類型。

AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Single>>)

使用「快照集視窗」 (SI 術語,計算對浮點數的平方平均) 。 請注意,累積器在內部是 float 資料類型。

AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt16>>)

使用「snapshot windows」 (SI 術語) ,計算跨 ushorts 匯總的平方時間平均。 請注意,累積器在內部是 ulong 資料類型。

AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt32>>)

使用「快照集視窗」 (SI 術語) 計算正方形匯總的時間平均。 請注意,累積器在內部是 ulong 資料類型。

AverageSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt64>>)

使用「快照集視窗」 (SI 術語) ,計算跨 ulong 的平方匯總時間平均。 請注意,累積器在內部是 ulong 資料類型。

Cache<TKey,TPayload>(IStreamable<TKey,TPayload>, UInt64, Boolean, Boolean)

在立即呼叫訂閱時,快取可資料流程計算的完整結果。 此
呼叫將會封鎖,直到基礎查詢完全執行並快取結果為止。

Chop<TKey,TPayload>(IStreamable<TKey,TPayload>, Int64, Int64)

執行 'Chop' 運算子,以分割 (分割區,) 跨跳動界限的長時間間隔和邊緣。

ClipEventDuration<TKey,TPayload>(IStreamable<TKey,TPayload>, Int64)

傳遞每個事件的截斷版本,其中事件會以最大事件長度截斷。

ClipEventDuration<TKey,TPayload,TClip>(IStreamable<TKey,TPayload>, IStreamable<TKey,TClip>)

傳遞左側每個事件的截斷版本,其中左事件會由右側的第一個事件截斷,而 Vs 會在左側事件之後發生。 聯結條件沒有限制。

ClipEventDuration<TKey,TLeft,TRight,TJoinKey>(IStreamable<TKey, TLeft>, IStreamable<TKey,TRight>, Expression<Func<TLeft,TJoinKey>>, Expression<Func<TRight,TJoinKey>>)

傳遞左側每個事件的截斷版本,其中左邊事件會由右側的第一個事件截斷,其中 Vs 發生在左側事件之後、符合聯結條件,以及兩個數據流的索引鍵相符的位置。 快速聯結索引鍵比較子會傳入以提升效率。

ConsecutivePairs<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,TPayload,TResult>>)

尋找連續重複的事件模式

Count<TKey,TPayload>(IStreamable<TKey,TPayload>)

使用「快照集視窗」 (SI 術語) 來計算時間敏感性計數匯總。

CountNotNull<TKey,TPayload,TValue>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,TValue>>)

使用「快照集視窗」 (SI 術語,計算非 Null 值的時效計數匯總) 。

DefinePattern<TKey,TPayload>(IStreamable<TKey,TPayload>)

定義輸入資料流程中的資料可能相符的模式

DefinePattern<TKey,TPayload,TRegister,TAccumulator>(IStreamable<TKey,TPayload>, TRegister, TAccumulator)

定義輸入資料流程中的資料可能相符的模式

Detect<TKey,TPayload>(IStreamable<TKey,TPayload>, Func<IAbstractPatternRoot<TKey, TPayload,Empty,Boolean>,IPattern<TKey,TPayload,Empty,Boolean>>, Int64, Boolean, Boolean)

偵測傳入資料流程的模式。 接受增強型正則運算式作為輸入。 使用 Regex.* API 或直接 AFA 規格建立 AFA。

Detect<TKey,TPayload,TRegister>(IStreamable<TKey,TPayload>, TRegister, Func<IAbstractPatternRoot<TKey,TPayload,TRegister,Boolean>,IPattern<TKey, TPayload,TRegister,Boolean>>, Int64, Boolean, Boolean)

偵測傳入資料流程的模式。 接受增強型正則運算式作為輸入。 使用 Regex.* API 或直接 AFA 規格建立 AFA。

Detect<TKey,TPayload,TRegister,TAccumulator>(IStreamable<TKey, TPayload>, TRegister, TAccumulator, Func<IAbstractPatternRoot<TKey, TPayload,TRegister,TAccumulator>,IPattern<TKey,TPayload,TRegister, TAccumulator>>, Int64, Boolean, Boolean)

偵測傳入資料流程的模式。 接受增強型正則運算式作為輸入。 使用 Regex.* API 或直接 AFA 規格建立 AFA。

Detect<TKey,TPayload,TRegister,TAccumulator>(IStreamable<TKey,TPayload>, Afa<TPayload,TRegister,TAccumulator>, Int64, Boolean, Boolean)

偵測傳入資料流程的模式。 接受擴增的有限自動化 (AFA) 作為輸入。 使用 Regex.* API 或直接 AFA 規格建立 AFA。

Distinct<TKey,TPayload>(IStreamable<TKey,TPayload>)

篩選出每個快照集的任何重複專案

Distinct<TKey,TInput,TResult>(IStreamable<TKey,TInput>, Expression<Func<TInput,TResult>>)

移除每個時間戳記的部分重複專案。 如果指定的運算式及其時間戳記符合兩個事件,則會被視為重複事件。

ExtendLifetime<TKey,TPayload>(IStreamable<TKey,TPayload>, Int64)

建立資料流程,以固定數量擴充所有事件存留期。

FollowedByImmediate<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Boolean>>, Expression<Func<TPayload, Boolean>>, Expression<Func<TPayload,TPayload,TResult>>, Int64)

尋找 B (後面緊接著的模式,且沒有任何其他中繼事件) , (嚴格小於指定時間持續時間)

FollowedByImmediate<TKey,TPayload,TPayload2,TResult>(IStreamable<TKey, TPayload>, IStreamable<TKey,TPayload2>, Expression<Func<TPayload, Boolean>>, Expression<Func<TPayload2,Boolean>>, Expression<Func<TPayload, TPayload2,TResult>>, Int64)

尋找左邊的 A 模式,後面緊接著 B 右邊 (,沒有其他中繼事件) , (嚴格小於指定時間持續時間)

GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TState2, TOutput2,TState3,TOutput3,TOutput>(IStreamable<TOuterKey,TInput>, Expression<Func<TInput,TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput2,TOutput3,TOutput>>)

依索引鍵選取器將輸入事件分組,並將多個匯總套用至每個群組上的「快照集視窗」 (SI 術語) 。

GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TState2, TOutput2,TState3,TOutput3,TState4,TOutput4,TOutput>(IStreamable<TOuterKey, TInput>, Expression<Func<TInput,TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput2,TOutput3,TOutput4,TOutput>>)

依索引鍵選取器將輸入事件分組,並將多個匯總套用至每個群組上的「快照集視窗」 (SI 術語) 。

GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TState2, TOutput2,TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TOutput>(IStreamable<TOuterKey, TInput>, Expression<Func<TInput,TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput>>)

依索引鍵選取器將輸入事件分組,並將多個匯總套用至每個群組上的「快照集視窗」 (SI 術語) 。

GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TState2, TOutput2,TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6, TOutput6,TOutput>(IStreamable<TOuterKey,TInput>, Expression<Func<TInput, TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey,TInnerKey>, TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput>>)

依索引鍵選取器將輸入事件分組,並將多個匯總套用至每個群組上的「快照集視窗」 (SI 術語) 。

GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TState2, TOutput2,TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6, TOutput6,TState7,TOutput7,TOutput>(IStreamable<TOuterKey,TInput>, Expression<Func<TInput,TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState7,TOutput7>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7, TOutput>>)

依索引鍵選取器將輸入事件分組,並將多個匯總套用至每個群組上的「快照集視窗」 (SI 術語) 。

GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TState2, TOutput2,TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6, TOutput6,TState7,TOutput7,TState8,TOutput8,TOutput>(IStreamable<TOuterKey, TInput>, Expression<Func<TInput,TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState8,TOutput8>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7, TOutput8,TOutput>>)

依索引鍵選取器將輸入事件分組,並將多個匯總套用至每個群組上的「快照集視窗」 (SI 術語) 。

GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TState2, TOutput2,TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6, TOutput6,TState7,TOutput7,TState8,TOutput8,TState9,TOutput9,TOutput>(IStreamable<TOuterKey, TInput>, Expression<Func<TInput,TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState8,TOutput8>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState9,TOutput9>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7, TOutput8,TOutput9,TOutput>>)

依索引鍵選取器將輸入事件分組,並將多個匯總套用至每個群組上的「快照集視窗」 (SI 術語) 。

GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TState2, TOutput2,TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6, TOutput6,TState7,TOutput7,TState8,TOutput8,TState9,TOutput9,TState10, TOutput10,TOutput>(IStreamable<TOuterKey,TInput>, Expression<Func<TInput, TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey,TInnerKey>, TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState8,TOutput8>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState9,TOutput9>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState10,TOutput10>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7, TOutput8,TOutput9,TOutput10,TOutput>>)

依索引鍵選取器將輸入事件分組,並將多個匯總套用至每個群組上的「快照集視窗」 (SI 術語) 。

GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TState2, TOutput2,TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6, TOutput6,TState7,TOutput7,TState8,TOutput8,TState9,TOutput9,TState10, TOutput10,TState11,TOutput11,TOutput>(IStreamable<TOuterKey,TInput>, Expression<Func<TInput,TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState8,TOutput8>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState9,TOutput9>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState10,TOutput10>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState11,TOutput11>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7, TOutput8,TOutput9,TOutput10,TOutput11,TOutput>>)

依索引鍵選取器將輸入事件分組,並將多個匯總套用至每個群組上的「快照集視窗」 (SI 術語) 。

GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TState2, TOutput2,TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6, TOutput6,TState7,TOutput7,TState8,TOutput8,TState9,TOutput9,TState10, TOutput10,TState11,TOutput11,TState12,TOutput12,TOutput>(IStreamable<TOuterKey, TInput>, Expression<Func<TInput,TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState8,TOutput8>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState9,TOutput9>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState10,TOutput10>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState11,TOutput11>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState12,TOutput12>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7, TOutput8,TOutput9,TOutput10,TOutput11,TOutput12,TOutput>>)

依索引鍵選取器將輸入事件分組,並將多個匯總套用至每個群組上的「快照集視窗」 (SI 術語) 。

GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TState2, TOutput2,TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6, TOutput6,TState7,TOutput7,TState8,TOutput8,TState9,TOutput9,TState10, TOutput10,TState11,TOutput11,TState12,TOutput12,TState13,TOutput13, TOutput>(IStreamable<TOuterKey,TInput>, Expression<Func<TInput, TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey,TInnerKey>, TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState8,TOutput8>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState9,TOutput9>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState10,TOutput10>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState11,TOutput11>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState12,TOutput12>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState13,TOutput13>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7, TOutput8,TOutput9,TOutput10,TOutput11,TOutput12,TOutput13,TOutput>>)

依索引鍵選取器將輸入事件分組,並將多個匯總套用至每個群組上的「快照集視窗」 (SI 術語) 。

GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TState2, TOutput2,TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6, TOutput6,TState7,TOutput7,TState8,TOutput8,TState9,TOutput9,TState10, TOutput10,TState11,TOutput11,TState12,TOutput12,TState13,TOutput13, TState14,TOutput14,TOutput>(IStreamable<TOuterKey,TInput>, Expression<Func<TInput, TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey,TInnerKey>, TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState8,TOutput8>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState9,TOutput9>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState10,TOutput10>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState11,TOutput11>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState12,TOutput12>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState13,TOutput13>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState14,TOutput14>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7, TOutput8,TOutput9,TOutput10,TOutput11,TOutput12,TOutput13,TOutput14, TOutput>>)

依索引鍵選取器將輸入事件分組,並將多個匯總套用至每個群組上的「快照集視窗」 (SI 術語) 。

GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TState2, TOutput2,TState3,TOutput3,TState4,TOutput4,TState5,TOutput5,TState6, TOutput6,TState7,TOutput7,TState8,TOutput8,TState9,TOutput9,TState10, TOutput10,TState11,TOutput11,TState12,TOutput12,TState13,TOutput13, TState14,TOutput14,TState15,TOutput15,TOutput>(IStreamable<TOuterKey, TInput>, Expression<Func<TInput,TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState3,TOutput3>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState4,TOutput4>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState5,TOutput5>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState6,TOutput6>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState7,TOutput7>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState8,TOutput8>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState9,TOutput9>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState10,TOutput10>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState11,TOutput11>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState12,TOutput12>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState13,TOutput13>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState14,TOutput14>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState15,TOutput15>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput2,TOutput3,TOutput4,TOutput5,TOutput6,TOutput7, TOutput8,TOutput9,TOutput10,TOutput11,TOutput12,TOutput13,TOutput14, TOutput15,TOutput>>)

依索引鍵選取器將輸入事件分組,並將多個匯總套用至每個群組上的「快照集視窗」 (SI 術語) 。

GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TOutput>(IStreamable<TOuterKey, TInput>, Expression<Func<TInput,TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState1,TOutput1>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput>>)

依索引鍵選取器將輸入事件分組,並將匯總套用至每個群組上的「快照集視窗」 (SI) 術語。

GroupAggregate<TOuterKey,TInput,TInnerKey,TState1,TOutput1,TState2, TOutput2,TOutput>(IStreamable<TOuterKey,TInput>, Expression<Func<TInput, TInnerKey>>, Func<Window<CompoundGroupKey<TOuterKey,TInnerKey>, TInput>,IAggregate<TInput,TState1,TOutput1>>, Func<Window<CompoundGroupKey<TOuterKey, TInnerKey>,TInput>,IAggregate<TInput,TState2,TOutput2>>, Expression<Func<GroupSelectorInput<TInnerKey>, TOutput1,TOutput2,TOutput>>)

依索引鍵選取器將輸入事件分組,並將多個匯總套用至每個群組上的「快照集視窗」 (SI 術語) 。

GroupApply<TOuterKey,TPayload,TInnerKey,TResult>(IStreamable<TOuterKey, TPayload>, Expression<Func<TPayload,TInnerKey>>, Func<IStreamable<CompoundGroupKey<TOuterKey, TInnerKey>,TPayload>,IStreamable<CompoundGroupKey<TOuterKey,TInnerKey>, TResult>>)

在資料流程上執行群組並套用作業。

GroupApply<TOuterKey,TPayload,TInnerKey,TBind,TResult>(IStreamable<TOuterKey, TPayload>, Expression<Func<TPayload,TInnerKey>>, Func<IStreamable<CompoundGroupKey<TOuterKey, TInnerKey>,TPayload>,IStreamable<CompoundGroupKey<TOuterKey,TInnerKey>, TBind>>, Expression<Func<GroupSelectorInput<TInnerKey>,TBind, TResult>>)

在資料流程上執行群組並套用作業。

GroupBy<TOuterKey,TPayload,TInnerKey>(IStreamable<TOuterKey,TPayload>, Expression<Func<TPayload,TInnerKey>>)

需要讓理解語法滿意。 請考慮改用 GroupApply。

HoppingWindowLifetime<TKey,TPayload>(IStreamable<TKey,TPayload>, Int64, Int64, Int64)

調整傳入事件的存留期,以在與匯總、跳動視窗搭配使用時實作。 在此實作中,每個傳入事件都會產生單一傳出事件,這表示後續匯總只會在輸入變更時產生輸出。 例如,如果收到單一點事件,且 windowSize、period 和 offset 分別為 100、2 和 0,則會產生單一匯總輸出,其存留期為 100 個刻度。

Join<TKey,TLeft,TRight,TResult>(IStreamable<TKey,TLeft>, IStreamable<TKey,TRight>, Expression<Func<TLeft,TRight,TResult>>)

在 2 個數據流之間執行跨產品

Join<TKey,TLeft,TRight,TResult>(IStreamable<TKey,TLeft>, IStreamable<TKey,TRight>, Expression<Func<TLeft,TRight,TResult>>, Int64)

在 2 個數據流之間執行跨產品

Join<TKey,TLeft,TRight,TJoinKey,TResult>(IStreamable<TKey,TLeft>, IStreamable<TKey,TRight>, Expression<Func<TLeft,TJoinKey>>, Expression<Func<TRight, TJoinKey>>, Expression<Func<TLeft,TRight,TResult>>)

在 2 個數據流之間執行等聯結,其中聯結金鑰的類型為 TJoinKey,並傳遞選取器從承載擷取聯結金鑰

Join<TKey,TLeft,TRight,TJoinKey,TResult>(IStreamable<TKey,TLeft>, IStreamable<TKey,TRight>, Expression<Func<TLeft,TJoinKey>>, Expression<Func<TRight, TJoinKey>>, Expression<Func<TLeft,TRight,TResult>>, OperationalHint)

在 2 個數據流之間執行等聯結,其中聯結金鑰的類型為 TJoinKey,並傳遞選取器從承載擷取聯結金鑰

Join<TKey,TLeft,TRight,TJoinKey,TResult>(IStreamable<TKey,TLeft>, IStreamable<TKey,TRight>, Expression<Func<TLeft,TJoinKey>>, Expression<Func<TRight, TJoinKey>>, Expression<Func<TLeft,TRight,TResult>>, Int64, OperationalHint)

在 2 個數據流之間執行等聯結,其中聯結金鑰的類型為 TJoinKey,並傳遞選取器從承載擷取聯結金鑰

LeftOuterJoin<TKey,TLeft,TRight,TJoinKey,TResult>(IStreamable<TKey, TLeft>, IStreamable<TKey,TRight>, Expression<Func<TLeft,TJoinKey>>, Expression<Func<TRight,TJoinKey>>, Expression<Func<TLeft,TRight, Boolean>>, Expression<Func<TLeft,TResult>>, Expression<Func<TLeft, TRight,TResult>>)

可串流作業的主要介面 - 使用者不應該建立實作此介面的新類別,而不需與開發小組直接通訊

LeftOuterJoin<TKey,TLeft,TRight,TJoinKey,TResult>(IStreamable<TKey, TLeft>, IStreamable<TKey,TRight>, Expression<Func<TLeft,TJoinKey>>, Expression<Func<TRight,TJoinKey>>, Expression<Func<TLeft,TResult>>, Expression<Func<TLeft,TRight,TResult>>)

要執行左外部聯結作業的宏。

LeftOuterJoin<TKey,TLeft,TRight,TJoinKey,TResult>(IStreamable<TKey, TLeft>, IStreamable<TKey,TRight>, Expression<Func<TLeft,TJoinKey>>, Expression<Func<TRight,TJoinKey>>, Expression<Func<TLeft,TResult>>, Expression<Func<TLeft,TRight,TResult>>, Int64)

要執行左外部聯結作業的宏。

Map<TOuterKey,TMapInput,TReduceInput>(IStreamable<TOuterKey,TMapInput>, Func<IStreamable<TOuterKey,TMapInput>,IStreamable<TOuterKey,TReduceInput>>)

單一輸入對應作業的對應階段。 允許對應程式上的串流邏輯規格。

Map<TOuterKey,TMapInput,TInnerKey,TReduceInput>(IStreamable<TOuterKey, TMapInput>, Func<IStreamable<TOuterKey,TMapInput>,IStreamable<TOuterKey, TReduceInput>>, Expression<Func<TReduceInput,TInnerKey>>)

單一輸入對應/縮減作業的對應階段。 允許對應器上的串流邏輯規格,以及下一個 (縮減) 階段的索引鍵選取器。

Max<TKey,TPayload>(IStreamable<TKey,TPayload>)

使用「快照集視窗」 (SI 術語) 計算時間敏感度上限匯總。

Max<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Comparison<TPayload>>)

使用「快照集視窗」 (SI 術語) 計算時間敏感度上限匯總。

Max<TKey,TPayload,T>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,T>>)

使用「快照集視窗」 (SI 術語) 計算時間敏感度上限匯總。

Max<TKey,TPayload,T>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,T>>, Expression<Comparison<T>>)

使用「快照集視窗」 (SI 術語) 提供的排序比較子,計算時間敏感度上限匯總。

Min<TKey,TPayload>(IStreamable<TKey,TPayload>)

使用「快照集視窗」 (SI 術語) 來計算時間敏感性最小匯總。

Min<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Comparison<TPayload>>)

使用「快照集視窗」 (SI 術語) 來計算時間敏感性最小匯總。

Min<TKey,TPayload,T>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,T>>)

使用「快照集視窗」 (SI 術語) 來計算時間敏感性最小匯總。

Min<TKey,TPayload,T>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,T>>, Expression<Comparison<T>>)

使用「快照集視窗」 (SI 術語,以提供的排序比較子) ,計算時間敏感度下限匯總。

Multicast<TKey,TPayload>(IStreamable<TKey,TPayload>, Int32)

透過可串流執行多播。 這可讓查詢寫入器在同一個實體輸入資料流程上執行多個子查詢。

Multicast<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Func<IStreamable<TKey,TPayload>,IStreamable<TKey,TResult>>)

透過可串流執行多播。 這可讓查詢寫入器在同一個實體輸入資料流程上執行多個子查詢。

Multicast<TKey,TPayloadLeft,TPayloadRight,TResult>(IStreamable<TKey, TPayloadLeft>, IStreamable<TKey,TPayloadRight>, Func<IStreamable<TKey, TPayloadLeft>,IStreamable<TKey,TPayloadRight>,IStreamable<TKey, TResult>>)

透過可串流執行多播。 這可讓查詢寫入器在同一個實體輸入資料流程上執行多個子查詢。

Pivot<TKey,TInput,TOutput,TGroupKey,TValue,TAggValue,TState>(IStreamable<TKey, TInput>, Expression<Func<TOutput>>, Expression<Func<TInput,TGroupKey>>, Expression<Func<TInput,String>>, Expression<Func<TInput,TValue>>, Func<Window<CompoundGroupKey<TKey,TGroupKey>,TValue>,IAggregate<TValue, TState,TAggValue>>)

可串流作業的主要介面 - 使用者不應該建立實作此介面的新類別,而不需與開發小組直接通訊

PointAtEnd<TKey,TPayload>(IStreamable<TKey,TPayload>)

建立串流,將所有清除報告為僅限插入的點資料流程, (將所有事件轉換成端點事件) 。

Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Byte>>)

使用「快照集視窗」 (SI 術語) ,計算位元組的時間敏感性產品匯總。

Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Decimal>>)

使用「快照集視窗」 (SI 術語) ,計算十進位數的時效性產品匯總。

Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Double>>)

使用「快照集視窗」 (SI 術語) ,計算雙精度浮點數的時效性產品匯總。

Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int16>>)

使用「快照集視窗」 (SI 術語) ,透過簡短計算時間敏感產品匯總。

Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int32>>)

使用「快照集視窗」 (SI 術語) ,針對 int 計算時間敏感的產品匯總。

Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int64>>)

使用「快照集視窗」 (SI 術語) ,以長時間計算區分時間的產品匯總。

Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Byte>>>)

使用「快照集視窗」 (SI 術語) ,計算具有時間敏感性的產品匯總。 請注意,Null 對總和沒有任何影響。

Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Decimal>>>)

使用「快照集視窗」 (SI 術語) ,透過可為 Null 的十進位數計算時間敏感產品匯總。 請注意,Null 對總和沒有任何影響。

Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Double>>>)

使用「快照集視窗」 (SI 術語) ,透過可為 Null 的雙精度浮點數計算時間敏感產品匯總。 請注意,Null 對總和沒有任何影響。

Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int16>>>)

使用「快照集視窗」 (SI 術語) ,透過可為 Null 的簡短計算時間敏感產品匯總。 請注意,Null 對總和沒有任何影響。

Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int32>>>)

使用「快照集視窗」 (SI 術語) ,針對可為 Null 的 int 計算時間敏感性產品匯總。 請注意,Null 對總和沒有任何影響。

Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int64>>>)

使用「快照集視窗」 (SI 術語) ,透過可為 Null 的長數計算時間敏感產品匯總。 請注意,Null 對總和沒有任何影響。

Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<BigInteger>>>)

使用「快照集視窗」 (SI 術語) ,計算可為 Null BigIntegers 的時間敏感性產品匯總。 請注意,Null 對總和沒有任何影響。

Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Complex>>>)

使用「快照集視窗」 (SI 術語) ,針對可為 Null 的複雜值計算時間敏感產品匯總。 請注意,Null 對總和沒有任何影響。

Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<SByte>>>)

使用「快照集視窗」 (SI 術語) ,針對可為 Null 的 sbytes 計算時間敏感產品匯總。 請注意,Null 對總和沒有任何影響。

Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Single>>>)

使用「快照集視窗」 (SI 術語) ,在可為 Null 的浮點數上計算時間敏感的產品匯總。 請注意,Null 對總和沒有任何影響。

Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt16>>>)

使用「快照集視窗」 (SI 術語) ,針對可為 Null 的 ushorts 計算時間敏感產品匯總。 請注意,Null 對總和沒有任何影響。

Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt32>>>)

使用「快照集視窗」 (SI 術語) ,計算可針對可為 Null 的 uint 進行時間敏感產品匯總。 請注意,Null 對總和沒有任何影響。

Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt64>>>)

使用「快照集視窗」 (SI 術語) ,在可為 Null 的 ulong 上計算時間敏感產品匯總。 請注意,Null 對總和沒有任何影響。

Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,BigInteger>>)

使用「快照集視窗」 (SI 術語) ,計算 BigIntegers 的時間敏感性產品匯總。

Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Complex>>)

使用「快照集視窗」 (SI 術語) ,計算複雜複本的時效性產品匯總。

Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,SByte>>)

使用「快照集視窗」 (SI 術語) ,計算跨位元組的時間敏感產品匯總。

Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Single>>)

使用「快照集視窗」 (SI 術語) ,計算浮點數的時效性產品匯總。

Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt16>>)

使用「快照集視窗」 (SI 術語) ,透過我們世代計算時間敏感的產品匯總。

Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt32>>)

使用「快照集視窗」 (SI 術語) ,透過 uint 計算時間敏感的產品匯總。

Product<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt64>>)

使用「快照集視窗」 (SI 術語) ,計算 ulong 上的時間敏感性產品匯總。

Publish<TKey,TPayload>(IStreamable<TKey,TPayload>)

透過可串流執行多播的動態版本。 這可讓查詢寫入器對相同的實體輸入資料流程執行多個子查詢 - 可以新增或移除資料流程。 由使用者決定資料流程沒有端邊緣,否則動態訂閱的訂閱者可能會收到格式不正確的資料流程 (結束邊緣,而沒有對應的起始邊緣) 。 使用方式:資料流程。Publish () ;流。訂閱 (...) ;流。Connect () ;流。訂閱 (...) ;

QuantizeLifetime<TKey,TPayload>(IStreamable<TKey,TPayload>, Int64, Int64, Int64)

調整傳入事件的存留期,以將每個事件的開始和結束時間貼齊到量化界限。 函式類似于跳動存留期運算式,不同之處在于所有開始邊緣都稍早移動或保持相同,而所有結束邊緣都會在稍後移動或保持相同。

RepetitiveHoppingWindowLifetime<TKey,TPayload>(IStreamable<TKey,TPayload>, Int64, Int64, Int64)

調整傳入事件的存留期,以在與匯總、重複跳動視窗搭配使用時實作。 在此實作中,每個傳入事件都會產生任意數目的傳出事件。 例如,如果收到單一點事件,且 windowSize、period 和 offset 分別為 100、2 和 0,則會產生 50 個完全相同的匯總輸出,每個都有 2 個刻度存留期。

Select<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,TResult>>)

透過可資料流程執行專案。

Select<TKey,TOld,TNew>(IStreamable<TKey,TOld>, Expression<Func<TNew>>, IDictionary<String,Expression<Func<TOld,Object>>>)

可串流作業的主要介面 - 使用者不應該建立實作此介面的新類別,而不需與開發小組直接通訊

Select<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Expression<Func<Int64,TPayload,TResult>>)

透過可資料流程執行專案。

Select<TKey,TOld,TNew,TField1>(IStreamable<TKey,TOld>, Expression<Func<TNew>>, Expression<Func<TNew,TField1>>, Expression<Func<TOld,TField1>>)

可串流作業的主要介面 - 使用者不應該建立實作此介面的新類別,而不需與開發小組直接通訊

Select<TKey,TOld,TNew,TField1,TField2>(IStreamable<TKey,TOld>, Expression<Func<TNew>>, Expression<Func<TNew,TField1>>, Expression<Func<TOld, TField1>>, Expression<Func<TNew,TField2>>, Expression<Func<TOld, TField2>>)

可串流作業的主要介面 - 使用者不應該建立實作此介面的新類別,而不需與開發小組直接通訊

SelectBatch<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Expression<Action<TPayload[],TResult[]>>)

透過可串流方式執行轉換、將承載分組成要轉換的批次,並提供要填入的輸出批次。 注意:此方法的預定語意相當於選取個別資料列。 這個方法的呼叫端是確保這些語意。

SelectByKey<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Expression<Func<TKey,TPayload,TResult>>)

透過可串流方式執行專案,相對於群組索引鍵。

SelectByKey<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Expression<Func<Int64,TKey,TPayload,TResult>>)

透過可串流方式執行專案,相對於群組索引鍵。

SelectMany<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,IEnumerable<TResult>>>)

這個選取許多用於產生一個承載的承載

SelectMany<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Expression<Func<Int64,TPayload,IEnumerable<TResult>>>)

這個選取許多用於產生一個承載的承載

SelectMany<TKey,TLeft,TRight,TResult>(IStreamable<TKey,TLeft>, Func<Empty,IStreamable<TKey,TRight>>, Expression<Func<TLeft,TRight,TResult>>)

這個選取許多用於衍生自理解語法的聯結,以及群組和套用中的非空白歸納器

SelectManyByKey<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Expression<Func<TKey,TPayload,IEnumerable<TResult>>>)

這個選取許多用於產生一個承載的承載

SelectManyByKey<TKey,TPayload,TResult>(IStreamable<TKey,TPayload>, Expression<Func<Int64,TKey,TPayload,IEnumerable<TResult>>>)

這個選取許多用於產生一個承載的承載

Sessionize<TKey,TPayload,TSessionKey,TResult>(IStreamable<TKey, TPayload>, Expression<Func<TPayload,Boolean>>, Expression<Func<TPayload, Boolean>>, Expression<Func<TPayload,TSessionKey>>, Expression<Func<TPayload, TPayload,TResult>>)

將開始和結束會話的資料流程轉換為單一會話資料流程,而我們會在意結束會話中的資料。 會話會在結束會話的時間戳記中輸出為點事件。

SessionTimeoutWindow<TKey,TPayload>(IStreamable<TKey,TPayload>, Int64, Int64)

視窗類型會在 Trill 中實作具有逾時的會話。 只要新的事件到達指定的逾時期間,就會延長目前的視窗。 一旦逾時期間經過,指定群組索引鍵) 沒有資料 (,視窗就會關閉。

ShiftEventLifetime<TKey,TPayload>(IStreamable<TKey,TPayload>, Int64)

依指定的時間量移動存留期

ShiftEventLifetime<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<Int64,Int64>>)

依 shiftSelector 轉移存留期,這是事件開始時間的函式

Stitch<TKey,TPayload>(IStreamable<TKey,TPayload>)

接合是 'Chop' 運算子的反向:當它同時找到 END 承載和 BEGIN 承載時,它會從資料流程中移除這兩者。 淨效果是,如果訊號中的值未變更,則資料流程不會有新的事件。 這最適用于人類眼睛;數學上,兩者應該相同

Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Byte>>)

使用「快照集視窗」 (SI 術語) ,計算位元組的時間敏感性總和匯總。

Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Decimal>>)

使用「快照集視窗」 (SI 術語) ,計算小數點的逾時總和匯總。

Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Double>>)

使用「快照集視窗」 (SI 術語) ,計算雙精度浮點數的總和匯總。

Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int16>>)

使用「快照集視窗」 (SI 術語) ,計算簡短的逾時總和匯總。

Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int32>>)

使用「快照集視窗」 (SI 術語) ,計算對 int 的時間敏感性總和匯總。

Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int64>>)

使用「快照集視窗」 (SI 術語) ,計算長時間的區分時間總和匯總。

Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Byte>>>)

使用「快照集視窗」 (SI 術語,計算可針對可為 Null 的位元組進行時間敏感總和匯總) 。 請注意,Null 對總和沒有任何影響。

Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Decimal>>>)

使用「快照集視窗」 (SI 術語) ,計算可針對可為 Null 的十進位數進行時間敏感總和匯總。 請注意,Null 對總和沒有任何影響。

Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Double>>>)

使用「快照集視窗」 (SI 術語) ,計算可 Null 雙精度浮點數的逾時總和匯總。 請注意,Null 對總和沒有任何影響。

Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int16>>>)

使用「快照集視窗」 (SI 術語) ,計算可為 Null 簡短的時間匯總。 請注意,Null 對總和沒有任何影響。

Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int32>>>)

使用「快照集視窗」 (SI 術語) ,針對可為 Null 的 int 計算時間敏感總和匯總。 請注意,Null 對總和沒有任何影響。

Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int64>>>)

使用「快照集視窗」 (SI 術語) 計算可 null 的匯總時間總和。 請注意,Null 對總和沒有任何影響。

Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<BigInteger>>>)

使用「快照集視窗」 (SI 術語) ,計算可為 Null BigIntegers 的時間敏感總和匯總。 請注意,Null 對總和沒有任何影響。

Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Complex>>>)

使用「快照集視窗」 (SI 術語) ,針對可為 Null 的複雜數計算時間敏感總和匯總。 請注意,Null 對總和沒有任何影響。

Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<SByte>>>)

使用「快照集視窗」 (SI 術語) ,計算可針對可為 Null 的 Sbytes 進行時間敏感總和匯總。 請注意,Null 對總和沒有任何影響。

Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Single>>>)

使用「快照集視窗」 (SI 術語) ,計算可 Null 浮點數的逾時總和匯總。 請注意,Null 對總和沒有任何影響。

Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt16>>>)

使用「快照集視窗」 (SI 術語) ,計算可為 Null 之 ushorts 的時間敏感總和匯總。 請注意,Null 對總和沒有任何影響。

Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt32>>>)

使用「快照集視窗」 (SI 術語) ,計算可為 Null 之 Uint 的逾時總和匯總。 請注意,Null 對總和沒有任何影響。

Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt64>>>)

使用「快照集視窗」 (SI 術語) ,計算可為 Null 的 ulong 匯總時間。 請注意,Null 對總和沒有任何影響。

Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,BigInteger>>)

使用「快照集視窗」 (SI 術語) 計算 BigIntegers 的時間敏感總和匯總。

Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Complex>>)

使用「快照集視窗」 (SI 術語) ,計算複雜資料的時間敏感總和匯總。

Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,SByte>>)

使用「快照集視窗」 (SI 術語) ,計算跨位元組的時間敏感總和匯總。

Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Single>>)

使用「快照集視窗」 (SI 術語) ,計算浮點數的逾時總和匯總。

Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt16>>)

使用「快照集視窗」 (SI 術語) ,計算跨我們世代的時間敏感總和匯總。

Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt32>>)

使用「快照集視窗」 (SI 術語) ,計算對 uint 的時間敏感總和匯總。

Sum<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt64>>)

使用「快照集視窗」 (SI 術語) ,計算 ulong 上的時間敏感性總和匯總。

SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Byte>>)

使用「快照集視窗」 (SI 術語) ,計算以位元組為單位匯總的平方時間總和。

SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Decimal>>)

使用「快照集視窗」 (SI 術語) ,計算十進位數的平方匯總時間總和。

SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Double>>)

使用「快照集視窗」 (SI 術語) 計算雙精度浮點數的平方總和。

SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int16>>)

使用「快照集視窗」 (SI 術語) ,計算簡短的平方匯總時間總和。

SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int32>>)

使用「快照視窗」 (SI 術語) ,計算正方形的匯總加總。

SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Int64>>)

使用「快照集視窗」 (SI 術語) ,計算長時間匯總的平方總和。

SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Byte>>>)

使用「快照集視窗」 (SI 術語,計算平方在可為 Null 的位元組上匯總的時間總和) 。 請注意,Null 對總和沒有任何影響。

SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Decimal>>>)

使用「快照集視窗」 (SI 術語,計算平方在可為 Null 的十進位數上匯總的時間總和) 。 請注意,Null 對總和沒有任何影響。

SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Double>>>)

使用「snapshot windows」 (SI 術語,計算平方加總與可為 Null 的雙精度浮點數) 。 請注意,Null 對總和沒有任何影響。

SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int16>>>)

使用「snapshot windows」 (SI 術語) ,計算可 null 簡短匯總的平方時間總和。 請注意,Null 對總和沒有任何影響。

SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int32>>>)

使用「snapshot windows」 (SI 術語,計算可針對可為 Null 的 ints 匯總) 的時間敏感性總和。 請注意,Null 對總和沒有任何影響。

SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Int64>>>)

使用「快照集視窗」 (SI 術語,計算平方在可為 Null 的長期間匯總的時間總和) 。 請注意,Null 對總和沒有任何影響。

SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<BigInteger>>>)

使用「snapshot windows」 (SI 術語,計算可 Null BigIntegers 的平方匯總時間總和) 。 請注意,Null 對總和沒有任何影響。

SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Complex>>>)

使用「snapshot windows」 (SI 術語,計算可 Null 複雜) 的平方匯總時間總和。 請注意,Null 對總和沒有任何影響。

SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<SByte>>>)

使用「snapshot windows」 (SI 術語,計算可針對可為 Null 的 sbytes 匯總的時間敏感性總和) 。 請注意,Null 對總和沒有任何影響。

SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<Single>>>)

使用「snapshot windows」 (SI 術語,計算可 Null 浮點數的平方匯總時間總和) 。 請注意,Null 對總和沒有任何影響。

SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt16>>>)

使用「snapshot windows」 (SI 術語,計算可針對可為 Null 之 ushorts 匯總的時間敏感性總和) 。 請注意,Null 對總和沒有任何影響。

SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt32>>>)

使用「快照集視窗」 (SI 術語,計算可針對可為 Null 的 uint 匯總時間總和) 。 請注意,Null 對總和沒有任何影響。

SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Nullable<UInt64>>>)

使用「snapshot windows」 (SI 術語,計算可 Null ulong 的平方匯總時間總和) 。 請注意,Null 對總和沒有任何影響。

SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,BigInteger>>)

使用「snapshot windows」 (SI 術語,計算 BigIntegers 上匯總) 的時間敏感性平方總和。

SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Complex>>)

使用「快照集視窗」 (SI 術語) ,計算「複雜」的平方匯總時間總和。

SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,SByte>>)

使用「快照集視窗」 (SI 術語) ,計算平方的時效總和。

SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Single>>)

使用「快照集視窗」 (SI 術語) ,計算浮點數的平方匯總時間總和。

SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt16>>)

使用「快照集視窗」 (SI 術語) ,計算跨 ushorts 的平方匯總時間總和。

SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt32>>)

使用「快照集視窗」 (SI 術語) ,計算跨 uint 的平方匯總時間總和。

SumSquares<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,UInt64>>)

使用「snapshot windows」 (SI 術語,計算對 ulong 的平方匯總時間總和) 。

ToBinaryStream<TKey,TPayload>(IStreamable<TKey,TPayload>, Stream, Boolean)

將可串流序列化為二進位資料流程

ToBinaryStream<TKey,TPayload>(IStreamable<TKey,TPayload>, String)

將可串流序列化為二進位檔案

TopK<TKey,TPayload>(IStreamable<TKey,TPayload>, Int32)

使用「快照集視窗」 (SI 術語,根據索引鍵選取器計算時間敏感度最高 k 的匯總) 。

TopK<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Comparison<TPayload>>, Int32)

使用「快照集視窗」 (SI 術語,根據索引鍵選取器計算時間敏感度最高 k 的匯總) 。

TopK<TKey,TPayload,T>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,T>>, Int32)

使用「快照集視窗」 (SI 術語,根據索引鍵選取器計算時間敏感度最高 k 的匯總) 。

TopK<TKey,TPayload,T>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,T>>, Expression<Comparison<T>>, Int32)

使用「快照集視窗」 (SI 術語,根據具有所提供排序比較子的索引鍵選取器,計算具有時間敏感性的前 K 個匯總 (SI) 術語。

TumblingWindowLifetime<TKey,TPayload>(IStreamable<TKey,TPayload>, Int64, Int64)

調整傳入事件的存留期,以在與匯總、輪轉視窗搭配使用時實作。 在此實作中,每個傳入事件都會產生單一傳出事件,這表示後續匯總只會在輸入變更時產生輸出。 例如,如果收到單一點事件,而配量和位移分別為 100 和 0,則會產生具有 100 個刻度存留期的單一匯總輸出。

Union<TKey,TPayload>(IStreamable<TKey,TPayload>, IStreamable<TKey,TPayload>)

等位是結合兩個類似架構資料流程的時態聯集

Unpivot<TKey,TInput,TPivotKey,TValue,TResult>(IStreamable<TKey, TInput>, Expression<Func<TResult>>, Expression<Func<TInput,TPivotKey>>, Expression<Func<TResult,String>>, Expression<Func<TResult,TValue>>)

將承載物件的資料流程輪替成對應至輸入承載資料之索引鍵-屬性值三倍的資料流程。

Where<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<TPayload,Boolean>>)

對可資料流程執行篩選,排除述詞評估為 false 的資料列。

WhereNotExists<TKey,TLeft,TRight>(IStreamable<TKey,TLeft>, IStreamable<TKey,TRight>)

在聯結條件為 true 的情況下執行左反半聯結, (聯結條件為 true) 。

WhereNotExists<TKey,TLeft,TRight>(IStreamable<TKey,TLeft>, IStreamable<TKey,TRight>, Int64)

在聯結條件為 true 的情況下執行左反半聯結, (聯結條件為 true) 。

WhereNotExists<TKey,TLeft,TRight,TJoinKey>(IStreamable<TKey,TLeft>, IStreamable<TKey,TRight>, Expression<Func<TLeft,TJoinKey>>, Expression<Func<TRight, TJoinKey>>)

使用傳入述詞做為聯結條件的 ,執行左反半聯結。

WhereNotExists<TKey,TLeft,TRight,TJoinKey>(IStreamable<TKey,TLeft>, IStreamable<TKey,TRight>, Expression<Func<TLeft,TJoinKey>>, Expression<Func<TRight, TJoinKey>>, Int64)

使用傳入述詞做為聯結條件的 ,執行左反半聯結。

WhereNotExists<TKey,TLeft,TRight,TJoinKey>(IStreamable<TKey,TLeft>, IStreamable<TKey,TRight>, Expression<Func<TLeft,TJoinKey>>, Expression<Func<TRight, TJoinKey>>, Expression<Func<TLeft,TRight,Boolean>>)

可串流作業的主要介面 - 使用者不應該建立實作此介面的新類別,而不需與開發小組直接通訊

適用於