CepStream(TPayload) 類別

表示來自任何使用者指定之裝載類型的事件資料流。

繼承階層

System. . :: . .Object
  Microsoft.ComplexEventProcessing.Linq..::..CepStream<(Of <(<'TPayload>)>)>

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

語法

public sealed class CepStream<TPayload>

型別參數

• TPayload
  資料流中的事件裝載類型。

CepStream<(Of <(<'TPayload>)>)> 型別公開下列成員。

方法

	名稱	說明
	Create(String)	使用 'TPayload' 類型的事件裝載建立未繫結資料流。
	Create(Uri, EventShape)	透過給定之已發行資料流的輸入，建立繫結資料流。
	Create(Uri, EventShape, AdvanceTimeSettings)	針對給定之已發行資料流的輸入，建立繫結資料流。
	Create(Application, Uri, EventShape)	透過給定之已發行資料流的輸入，建立繫結資料流。
	Create(String, Type, Object, EventShape)	從給定的輸入配接器 Factory 建立繫結資料流。
	Create(Application, Uri, EventShape, AdvanceTimeSettings)	針對給定之已發行資料流的輸入，建立繫結資料流。
	Create(String, Type, Object, EventShape, AdvanceTimeSettings)	從給定的輸入配接器 Factory 建立繫結資料流。
	Create(Application, String, Type, Object, EventShape)	從給定的輸入配接器 Factory 建立繫結資料流。
	Create(Application, String, Type, Object, EventShape, AdvanceTimeSettings)	從給定的輸入配接器 Factory 建立繫結資料流。
	Equals	(繼承自 Object。)
	ExtractInputStreams	擷取包含來自給定資料流定義之輸入資料流相關資訊的清單。
	Finalize	(繼承自 Object。)
	GetHashCode	(繼承自 Object。)
	GetType	(繼承自 Object。)
	MemberwiseClone	(繼承自 Object。)
	ToPublishedStreamQuery(Uri, String, String, EventShape, StreamEventOrder)	使用繫結至明確具名之已發行資料流的輸出建立查詢。查詢的輸出可以透過動態查詢撰寫來取用。在任何給定的時間，只有一個查詢能夠產生已發行資料流的事件。
	ToPublishedStreamQuery(Uri, Application, String, String, EventShape, StreamEventOrder)	使用繫結至明確具名之已發行資料流的輸出建立查詢。查詢的輸出可以透過動態查詢撰寫來取用。在任何給定的時間，只有一個查詢能夠產生已發行資料流的事件。
	ToQuery(String, String, EventShape, StreamEventOrder)	從具有未繫結輸出的資料流建立查詢。查詢的所有輸入都必須繫結至配接器、順序或其他查詢。查詢的輸出只可以透過動態查詢撰寫來取用。此查詢執行所在的應用程式是由資料流的定義所隱含。
	ToQuery(Application, String, String, EventShape, StreamEventOrder)	從具有未繫結輸出且執行於特定應用程式的資料流中建立查詢。查詢的所有輸入都必須繫結至配接器、順序或其他查詢。查詢的輸出只可以透過動態查詢撰寫來取用。
	ToQuery(String, String, Type, Object, EventShape, StreamEventOrder)	從繫結至輸出配接器的資料流建立查詢。輸出配接器是由配接器 Factory 及組態物件的類型所指定。此查詢執行所在的應用程式是由資料流的定義所隱含。
	ToQuery(String, String, Type, Object, EventShape, StreamEventOrder, Boolean)	從繫結至輸出配接器的資料流建立查詢。輸出配接器是由配接器 Factory 及組態物件的類型所指定。此查詢執行所在的應用程式是由資料流的定義所隱含。查詢可以指定為具有恢復功能。
	ToQuery(Application, String, String, Type, Object, EventShape, StreamEventOrder)	從繫結至執行於特定應用程式之輸出配接器的資料流中建立查詢。輸出配接器是由配接器 Factory 及組態物件的類型所指定。
	ToQuery(Application, String, String, Type, Object, EventShape, StreamEventOrder, Boolean)	從繫結至執行於特定應用程式之輸出配接器的資料流中建立查詢。輸出配接器是由配接器 Factory 及組態物件的類型所指定。查詢可以指定為具有恢復功能。
	ToString	(繼承自 Object。)

上層

擴充 方法

	名稱	說明
	AlterEventDuration< (Of < <' (TPayload> ) > > )	變更輸入事件的持續時間。這個方法並不會變更事件的開始時間。 (由 CepStream 定義。)
	AlterEventLifetime< (Of < <' (TPayload> ) > > )	改變資料流中的事件存留期間。這個方法可以同時變更事件的開始時間和結束時間。 (由 CepStream 定義。)
	ClipEventDuration< (Of < <' (TSource, TClip> ) > > )	將 sourceStream 中的事件存留期間縮短為與 matchExpression 相符之 clipStream 中下一個對應事件的開始時間。 (由 CepStream 定義。)
	CountByStartTimeWindow< (Of < <' (TPayload> ) > > )(UInt32)	已多載。 使用預設輸出原則，根據給定的唯一事件啟動次數，將輸入資料流事件分組到事件的視窗。當在不同時間啟動的新事件抵達時，此視窗會滑動。 (由 CepStream 定義。)
	CountByStartTimeWindow< (Of < <' (TPayload> ) > > )(UInt32, CountWindowOutputPolicy)	已多載。 根據給定的唯一事件啟動次數，將輸入資料流事件分組到事件的視窗。當在不同時間啟動的新事件抵達時，此視窗會滑動。 (由 CepStream 定義。)
	CountByStartTimeWindow< (Of < <' (TPayload> ) > > )(UInt32, WindowInputPolicy, CountWindowOutputPolicy)	已多載。 根據給定的唯一事件啟動次數，將輸入資料流事件分組到事件的視窗。當在不同時間啟動的新事件抵達時，此視窗會滑動。 (由 CepStream 定義。)
	GroupBy< (Of < <' (TPayload, TGroupingKey> ) > > )(Expression< (Of < <' (Func< (Of < <' (TPayload, TGroupingKey> ) > > )> ) > > ))	已多載。 依指定的群組索引鍵分割輸入資料流。 (由 CepStream 定義。)
	GroupBy< (Of < <' (TPayload, TGroupingKey, TResult> ) > > )(Expression< (Of < <' (Func< (Of < <' (TPayload, TGroupingKey> ) > > )> ) > > ), Expression< (Of < <' (Func< (Of < <' (TPayload, TResult> ) > > )> ) > > ))	已多載。 依指定的索引鍵選取器函數來分組來源資料流，然後使用元素選擇器函數投射結果。 (由 CepStream 定義。)
	HoppingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, TimeSpan)	已多載。 將資料流轉換為視窗資料流，其中每個成員都是使用預設輸出原則的 CepWindow。此視窗是由常數視窗大小和躍點大小時間範圍所定義。 (由 CepStream 定義。)
	HoppingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, TimeSpan, DateTime)	已多載。 將資料流轉換為視窗資料流，其中每個成員都是使用預設輸出原則的 CepWindow。此視窗是由常數視窗大小和躍點大小時間範圍所定義。您也可以提供對齊時間做為視窗起點的參考。 (由 CepStream 定義。)
	HoppingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, TimeSpan, HoppingWindowOutputPolicy)	已多載。 將資料流轉換為視窗資料流，其中每個成員都是一個 CepWindow。此視窗是由常數視窗大小和躍點大小時間範圍所定義。 (由 CepStream 定義。)
	HoppingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, TimeSpan, DateTime, HoppingWindowOutputPolicy)	已多載。 將資料流轉換為視窗資料流，其中每個成員都是一個 CepWindow。此視窗是由常數視窗大小和躍點大小時間範圍所定義。您也可以提供對齊時間做為視窗起點的參考。 (由 CepStream 定義。)
	HoppingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, TimeSpan, WindowInputPolicy, HoppingWindowOutputPolicy)	已多載。 將資料流轉換為視窗資料流，其中每個成員都是一個 CepWindow。此視窗是由常數視窗大小和躍點大小時間範圍所定義。您也可以提供對齊時間做為視窗起點的參考。 (由 CepStream 定義。)
	HoppingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, TimeSpan, DateTime, WindowInputPolicy, HoppingWindowOutputPolicy)	已多載。 此視窗是由常數視窗大小和躍點大小時間範圍所定義。您也可以提供對齊時間做為視窗起點的參考。 (由 CepStream 定義。)
	IsEmpty< (Of < <' (TPayload> ) > > )	查詢中用來表示左方反半聯結 (LASJ) 的函數。 (由 CepStream 定義。)
	Join< (Of < <' (TOuter, TInner, TKey, TResult> ) > > )	在給定的聯結索引鍵上，將外部資料流的事件與內部資料流的事件聯結在一起。 (由 CepStream 定義。)
	Select< (Of < <' (TPayload, TResult> ) > > )	使用投射運算式投射來自輸入資料流的事件。 (由 CepStream 定義。)
	SelectMany< (Of < <' (TInput, TBind, TResult> ) > > )	根據兩個輸入資料流的交叉聯結，產生資料流。 (由 CepStream 定義。)
	ShiftEventTime< (Of < <' (TPayload> ) > > )(Expression< (Of < <' (Func< (Of < <' (CepEvent, DateTime> ) > > )> ) > > ))	已多載。 將事件的開始時間移位至新的時間戳記，而不變更存留期。 (由 CepStream 定義。)
	ShiftEventTime< (Of < <' (TPayload> ) > > )(Expression< (Of < <' (Func< (Of < <' (CepEvent, TimeSpan> ) > > )> ) > > ))	已多載。 以指定的時間範圍將事件的開始時間移位，而不變更存留期。 (由 CepStream 定義。)
	SnapshotWindow< (Of < <' (TPayload> ) > > )() () () ()	已多載。 將資料流轉換為視窗資料流，其中每個成員都是使用預設輸出原則的 CepWindow。每個視窗都是由資料流中最接近之事件端點所定義的快照集視窗。 (由 CepStream 定義。)
	SnapshotWindow< (Of < <' (TPayload> ) > > )(SnapshotWindowOutputPolicy)	已多載。 將資料流轉換為視窗資料流，其中每個成員都是一個 CepWindow。每個視窗都是由資料流中最接近之事件端點所定義的快照集視窗。 (由 CepStream 定義。)
	SnapshotWindow< (Of < <' (TPayload> ) > > )(WindowInputPolicy, SnapshotWindowOutputPolicy)	已多載。 將資料流轉換為視窗資料流，其中每個成員都是一個 CepWindow。每個視窗都是由資料流中最接近之事件端點所定義的快照集視窗。 (由 CepStream 定義。)
	ToEdgeEnumerable< (Of < <' (TPayload> ) > > )() () () ()	已多載。 將邊緣事件的 CepStream 轉換成實作 IEnumerable 介面的事件接收。事件的順序為 FullyOrdered。 (由 CepStream 定義。)
	ToEdgeEnumerable< (Of < <' (TPayload> ) > > )(StreamEventOrder)	已多載。 以指定的事件順序將邊緣事件的 CepStream 轉換成實作 IEnumerable 介面的事件接收。 (由 CepStream 定義。)
	ToEdgeObservable< (Of < <' (TPayload> ) > > )() () () ()	已多載。 將邊緣事件的 CepStream 轉換成實作 IObservable 介面的事件接收。事件的順序為 FullyOrdered。 (由 ObservableCepStream 定義。)
	ToEdgeObservable< (Of < <' (TPayload> ) > > )(StreamEventOrder)	已多載。 以指定的事件順序將邊緣事件的 CepStream 轉換成實作 IObservable 介面的事件接收。 (由 ObservableCepStream 定義。)
	ToEnumerable< (Of < <' (TPayload> ) > > )() () () ()	已多載。 藉由移除事件標頭及捨棄 CTI 事件的方式將事件資料流轉換為可列舉輸出。 (由 CepStream 定義。)
	ToEnumerable< (Of < <' (TPayload> ) > > )(StreamEventOrder)	已多載。 藉由移除事件標頭及捨棄 CTI 事件的方式，以指定的事件順序將事件資料流轉換為可列舉輸出。 (由 CepStream 定義。)
	ToIntervalEnumerable< (Of < <' (TPayload> ) > > )() () () ()	已多載。 將間隔事件的 CepStream 轉換成實作 IEnumerable 介面的事件接收。事件的順序為 FullyOrdered。 (由 CepStream 定義。)
	ToIntervalEnumerable< (Of < <' (TPayload> ) > > )(StreamEventOrder)	已多載。 以指定的事件順序將間隔事件的 CepStream 轉換成實作 IEnumerable 介面的事件接收。 (由 CepStream 定義。)
	ToIntervalObservable< (Of < <' (TPayload> ) > > )() () () ()	已多載。 將間隔事件的 CepStream 轉換成實作 IObservable 介面的事件接收。事件的順序為 FullyOrdered。 (由 ObservableCepStream 定義。)
	ToIntervalObservable< (Of < <' (TPayload> ) > > )(StreamEventOrder)	已多載。 以指定的事件順序將間隔事件的 CepStream 轉換成實作 IObservable 介面的事件接收。 (由 ObservableCepStream 定義。)
	ToObservable< (Of < <' (TPayload> ) > > )() () () ()	已多載。 藉由移除事件標頭及捨棄 CTI 事件的方式將事件資料流轉換為可觀察輸出。 (由 ObservableCepStream 定義。)
	ToObservable< (Of < <' (TPayload> ) > > )(StreamEventOrder)	已多載。 藉由移除事件標頭及捨棄 CTI 事件的方式，以指定的事件順序將事件資料流轉換為可觀察輸出。 (由 ObservableCepStream 定義。)
	ToPointEnumerable< (Of < <' (TPayload> ) > > )() () () ()	已多載。 將時間點事件的 CepStream 轉換成實作 IEnumerable 介面的事件接收。事件的順序為 FullyOrdered。 (由 CepStream 定義。)
	ToPointEnumerable< (Of < <' (TPayload> ) > > )(StreamEventOrder)	已多載。 以指定的事件順序將時間點事件的 CepStream 轉換成實作 IEnumerable 介面的事件接收。 (由 CepStream 定義。)
	ToPointEventStream< (Of < <' (TPayload> ) > > )	透過只保留事件開始時間，將輸入資料流中的事件變更為時間點事件。 (由 CepStream 定義。)
	ToPointObservable< (Of < <' (TPayload> ) > > )() () () ()	已多載。 將時間點事件的 CepStream 轉換成實作 IObservable 介面的事件接收。事件的順序為 FullyOrdered。 (由 ObservableCepStream 定義。)
	ToPointObservable< (Of < <' (TPayload> ) > > )(StreamEventOrder)	已多載。 以指定的事件順序將時間點事件的 CepStream 轉換成實作 IObservable 介面的事件接收。 (由 ObservableCepStream 定義。)
	TumblingWindow< (Of < <' (TPayload> ) > > )(TimeSpan)	已多載。 將資料流轉換為視窗資料流，其中每個成員都是使用預設輸出原則的 CepWindow。輪轉視窗是一種特殊種類的跳動視窗，其中視窗大小和躍點大小相同。 (由 CepStream 定義。)
	TumblingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, DateTime)	已多載。 將資料流轉換為視窗資料流，其中每個成員都是使用預設輸出原則的 CepWindow。輪轉視窗是一種特殊種類的跳動視窗，其中視窗大小和躍點大小相同。您也可以提供對齊時間做為視窗起點的參考。 (由 CepStream 定義。)
	TumblingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, HoppingWindowOutputPolicy)	已多載。 將資料流轉換為視窗資料流，其中每個成員都是一個 CepWindow。輪轉視窗是一種特殊種類的跳動視窗，其中視窗大小和躍點大小相同。 (由 CepStream 定義。)
	TumblingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, DateTime, HoppingWindowOutputPolicy)	已多載。 將資料流轉換為視窗資料流，其中每個成員都是一個 CepWindow。輪轉視窗是一種特殊種類的跳動視窗，其中視窗大小和躍點大小相同。您也可以提供對齊時間做為視窗起點的參考。 (由 CepStream 定義。)
	TumblingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, WindowInputPolicy, HoppingWindowOutputPolicy)	已多載。 將資料流轉換為視窗資料流，其中每個成員都是一個 CepWindow。輪轉視窗是一種特殊種類的跳動視窗，其中視窗大小和躍點大小相同。您也可以提供對齊時間做為視窗起點的參考。 (由 CepStream 定義。)
	TumblingWindow< (Of < <' (TPayload> ) > > )(TimeSpan, DateTime, WindowInputPolicy, HoppingWindowOutputPolicy)	已多載。 將資料流轉換為視窗資料流，其中每個成員都是一個 CepWindow。輪轉視窗是一種特殊種類的跳動視窗，其中視窗大小和躍點大小相同。您也可以提供對齊時間做為視窗起點的參考。 (由 CepStream 定義。)
	Union< (Of < <' (TPayload> ) > > )	將兩個資料流聯集在一起放在一個資料流中。 (由 CepStream 定義。)
	Where< (Of < <' (TPayload> ) > > )	使用給定的篩選函數來篩選輸入資料流中的事件。 (由 CepStream 定義。)

上層

備註

您必須先提供適當的資料流定義，才能寫入 CEP 查詢。這個類別會提供各種建立 CepStream 物件的方法。

執行緒安全性

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

請參閱

參考

Microsoft.ComplexEventProcessing.Linq 命名空間