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