QStreamable 類別

表示 IQStreamable 暫時資料流查詢的運算子擴充方法。

繼承階層

System.Object
  Microsoft.ComplexEventProcessing.Linq.QStreamable

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

語法

'宣告
<ExtensionAttribute> _
Public NotInheritable Class QStreamable
'用途

public static class QStreamable

[ExtensionAttribute]
public ref class QStreamable abstract sealed

[<AbstractClassAttribute>]
[<SealedAttribute>]
type QStreamable =  class end

public final class QStreamable

QStreamable 型別公開下列成員。

方法

	名稱	說明
	AlterEventDuration<TPayload>	改變事件的持續時間，而不影響開始時間。
	AlterEventLifetime<TPayload>	改變事件的存留期間。
	AlterEventStartTime<TPayload>	改變事件的開始時間，而不影響持續時間。
	ClipEventDuration<TSource, TClip>(IQStreamable<TSource>, IQStreamable<TClip>, Expression<Func<TSource, TClip, Boolean>>)	將 [來源] 中事件的結束時間裁剪到 [裁剪] 比對 [述詞] 中下一個對應事件的開始時間。
	ClipEventDuration<TSource, TClip, TKey>(IQStreamable<TSource>, IQStreamable<TClip>, Expression<Func<TSource, TKey>>, Expression<Func<TClip, TKey>>)	將 [來源] 中事件的結束時間裁剪到具有相等索引鍵值的 [裁剪] 中下一個對應事件的開始時間。
	CountWindow<TPayload>	根據計數產生視窗型資料流。每一個視窗都是由包含 [計數] 唯一開始時間的事件所組成。當新的事件抵達時如果有相異的開始時間，此視窗會滑動。
	GroupBy<TPayload, TKey>(IQStreamable<TPayload>, Expression<Func<TPayload, TKey>>)	資料分割運算子。
	GroupBy<TSource, TKey, TResult>(IQStreamable<TSource>, Expression<Func<TSource, TKey>>, Expression<Func<TSource, TResult>>)	資料分割運算子。
	HoppingWindow<TPayload>(IQStreamable<TPayload>, TimeSpan, TimeSpan)	根據視窗定義產生視窗型資料流。跳動視窗是以視窗持續時間及代表視窗期間的躍點大小為特色。
	HoppingWindow<TPayload>(IQStreamable<TPayload>, TimeSpan, TimeSpan, DateTime)	根據視窗定義產生視窗型資料流。跳動視窗是以視窗持續時間及代表視窗期間的躍點大小為特色。
	Join<TLeft, TRight, TKey, TResult>	具有一致存留期間及相符索引鍵值的聯結事件。
	LeftAntiJoin<TLeft, TRight>(IQStreamable<TLeft>, IQStreamable<TRight>, Expression<Func<TLeft, TRight, Boolean>>)	當 [左方] 事件與任何比對的 [右方] 事件 (根據 [述詞] 來比對事件) 不一致時，就會傳回左方事件。
	LeftAntiJoin<TLeft, TRight, TKey>(IQStreamable<TLeft>, IQStreamable<TRight>, Expression<Func<TLeft, TKey>>, Expression<Func<TRight, TKey>>)	當 [左方] 事件與任何比對的 [右方] 事件 (根據索引鍵來比對事件) 不一致時，就會傳回左方事件。
	Multicast<TSource, TResult>	多點傳送運算子。
	OrderBy<TPayload, TKey>	根據索引鍵排序視窗的內容。
	OrderByDescending<TPayload, TKey>	以遞減順序根據索引鍵排序視窗的內容。
	Scan<TSourceEvent, TSource, TResult>	使用使用者定義的資料流運算子掃描資料流。
	Select<TSource, TResult>(IQOrderedWindow<TSource>, Expression<Func<TSource, TResult>>)	將運算子投射到排序的視窗。
	Select<TSource, TResult>(IQStreamable<TSource>, Expression<Func<TSource, TResult>>)	投射運算子。
	Select<TSource, TResult>(IQWindowedStreamable<TSource>, Expression<Func<CepWindow<TSource>, TResult>>)	支援視窗彙總計算的投射方法。
	SelectMany<TSource, TResult>(IQWindowedStreamable<TSource>, Expression<Func<IQWindowSource<TSource>, IQWindowResult<TResult>>>)	在給定函數時，傳回從視窗到視窗結果之結果資料流的繫結運算子。
	SelectMany<TKey, TSource, TResult>(IQPartitionedStreamable<TKey, TSource>, Expression<Func<IQStreamable<TSource>, IQStreamable<TResult>>>)	分割資料流的合併運算子。
	SelectMany<TLeft, TRight, TResult>(IQStreamable<TLeft>, Expression<Func<Unit, IQStreamable<TRight>>>, Expression<Func<TLeft, TRight, TResult>>)	交叉聯結運算子。
	SelectMany<TSource, TBind, TResult>(IQWindowedStreamable<TSource>, Expression<Func<IQWindowSource<TSource>, IQWindowResult<TBind>>>, Expression<Func<Unit, TBind, TResult>>)	在給定函數時，傳回從視窗到視窗結果之結果資料流的繫結運算子。
	SelectMany<TKey, TSource, TBind, TResult>(IQPartitionedStreamable<TKey, TSource>, Expression<Func<IQStreamable<TSource>, IQStreamable<TBind>>>, Expression<Func<IKey<TKey>, TBind, TResult>>)	分割資料流的合併運算子。
	SelectMany<TKey, TSource, TBind, TResult>(IQPartitionedStreamable<TKey, TSource>, Expression<Func<IQStreamable<TSource>, IQWindowedStreamable<TBind>>>, Expression<Func<IKey<TKey>, CepWindow<TBind>, TResult>>)	分割資料流的合併彙總運算子。
	ShiftEventTime<TPayload>	將事件移位 [shiftSelector] 參數所指定的位移數。
	SnapshotWindow<TPayload>	根據快照集產生視窗型資料流。視窗是由 [來源] 中的事件界限所定義。
	Take<TPayload>(IQOrderedWindow<TPayload>, UInt32)	從排序視窗取得上方 [計數] 元素。如果有繫結，則會傳回次序最低的所有元素。
	Take<TSource, TResult>(IQOrderedWindow<TSource>, UInt32, Expression<Func<CepRankedEvent<TSource>, TResult>>)	從排序視窗取得上方 [計數] 元素。如果有繫結，則會傳回次序最低的所有元素。
	ThenBy<TPayload, TKey>	將排序索引鍵加入至排序視窗定義。
	ThenByDescending<TPayload, TKey>	將排序索引鍵加入至排序視窗定義，其中的索引鍵用於遞減順序。
	ToPointEventStream<TPayload>	將輸入資料流中的事件轉換為點事件。
	TumblingWindow<TPayload>(IQStreamable<TPayload>, TimeSpan)	根據視窗定義產生視窗型資料流。
	TumblingWindow<TPayload>(IQStreamable<TPayload>, TimeSpan, DateTime)	根據視窗定義產生視窗型資料流。
	Union<TPayload>	等位運算子。
	UserDefinedOperator<TSource, TResult>(IQWindowSource<TSource>, Expression<Func<CepOperator<TSource, TResult>>>)	將使用者定義的運算子套用至視窗。
	UserDefinedOperator<TSource, TResult>(IQWindowSource<TSource>, Expression<Func<CepTimeSensitiveOperator<TSource, TResult>>>)	將使用者定義的運算子套用至視窗。
	Where<TPayload>	選取運算子。

上層

執行緒安全性

這個型別的任何公用 static (在 Visual Basic 中為 Shared) 成員都是執行緒安全的。並不是所有的執行個體成員都保證可以用於所有的執行緒。

請參閱

參考

Microsoft.ComplexEventProcessing.Linq 命名空間