IQStreamable<TPayload> 方法

包含保護的成員
包含繼承的成員

IQStreamable<TPayload> 型別公開下列成員。

擴充 方法

  名稱 說明
公用擴充方法 AlterEventDuration<TPayload> 改變事件的持續時間,而不影響開始時間。 (由 QStreamable 定義。)
公用擴充方法 AlterEventLifetime<TPayload> 改變事件的存留期間。 (由 QStreamable 定義。)
公用擴充方法 AlterEventStartTime<TPayload> 改變事件的開始時間,而不影響持續時間。 (由 QStreamable 定義。)
公用擴充方法 Bind<TPayload>(Func<Nullable<DateTimeOffset>, Int32, IRemoteObserver<EdgeEvent<TPayload>>>) 已多載。 將暫時資料流繫結至根據上限標準和位移參數化的邊緣事件觀察器。 (由 RemoteProvider 定義。)
公用擴充方法 Bind<TPayload>(IRemoteObserver<EdgeEvent<TPayload>>) 已多載。 將暫時資料流繫結至邊緣事件觀察器接收。 (由 RemoteProvider 定義。)
公用擴充方法 Bind<TPayload>(IRemoteObserver<IntervalEvent<TPayload>>) 已多載。 將暫時資料流繫結至間隔事件觀察器接收。 (由 RemoteProvider 定義。)
公用擴充方法 Bind<TPayload>(Func<Nullable<DateTimeOffset>, Int32, IRemoteObserver<IntervalEvent<TPayload>>>) 已多載。 將暫時資料流繫結至根據上限標準和位移參數化的間隔事件觀察器。 (由 RemoteProvider 定義。)
公用擴充方法 Bind<TPayload>(IRemoteObserver<TPayload>) 已多載。 將暫時資料流繫結至觀察器接收。 (由 RemoteProvider 定義。)
公用擴充方法 Bind<TPayload>(IRemoteStreamableSink<TPayload>) 已多載。 將暫時資料流來源繫結至暫時資料流接收。 (由 RemoteProvider 定義。)
公用擴充方法 Bind<TPayload>(IRemoteObserver<PointEvent<TPayload>>) 已多載。 將暫時資料流繫結至時間點事件觀察器接收。 (由 RemoteProvider 定義。)
公用擴充方法 Bind<TPayload>(Func<Nullable<DateTimeOffset>, Int32, IRemoteObserver<PointEvent<TPayload>>>) 已多載。 將暫時資料流繫結至上限標準和位移上參數化的時間點事件觀察器。 (由 RemoteProvider 定義。)
公用擴充方法 ClipEventDuration<TSource, TClip>(IQStreamable<TClip>, Expression<Func<TSource, TClip, Boolean>>) 已多載。 將 [來源] 中事件的結束時間裁剪到 [裁剪] 比對 [述詞] 中下一個對應事件的開始時間。 (由 QStreamable 定義。)
公用擴充方法 ClipEventDuration<TSource, TClip, TKey>(IQStreamable<TClip>, Expression<Func<TSource, TKey>>, Expression<Func<TClip, TKey>>) 已多載。 將 [來源] 中事件的結束時間裁剪到具有相等索引鍵值的 [裁剪] 中下一個對應事件的開始時間。 (由 QStreamable 定義。)
公用擴充方法 CountWindow<TPayload> 根據計數產生視窗型資料流。每一個視窗都是由包含 [計數] 唯一開始時間的事件所組成。當新的事件抵達時如果有相異的開始時間,此視窗會滑動。 (由 QStreamable 定義。)
公用擴充方法 Deploy<TPayload> 部署遠端暫時資料流。 (由 RemoteProvider 定義。)
公用擴充方法 GroupBy<TPayload, TKey>(Expression<Func<TPayload, TKey>>) 已多載。 資料分割運算子。 (由 QStreamable 定義。)
公用擴充方法 GroupBy<TSource, TKey, TResult>(Expression<Func<TSource, TKey>>, Expression<Func<TSource, TResult>>) 已多載。 資料分割運算子。 (由 QStreamable 定義。)
公用擴充方法 HoppingWindow<TPayload>(TimeSpan, TimeSpan) 已多載。 根據視窗定義產生視窗型資料流。跳動視窗是以視窗持續時間及代表視窗期間的躍點大小為特色。 (由 QStreamable 定義。)
公用擴充方法 HoppingWindow<TPayload>(TimeSpan, TimeSpan, DateTime) 已多載。 根據視窗定義產生視窗型資料流。跳動視窗是以視窗持續時間及代表視窗期間的躍點大小為特色。 (由 QStreamable 定義。)
公用擴充方法 Join<TLeft, TRight, TKey, TResult> 具有一致存留期間及相符索引鍵值的聯結事件。 (由 QStreamable 定義。)
公用擴充方法 LeftAntiJoin<TLeft, TRight>(IQStreamable<TRight>, Expression<Func<TLeft, TRight, Boolean>>) 已多載。 當 [左方] 事件與任何比對的 [右方] 事件 (根據 [述詞] 來比對事件) 不一致時,就會傳回左方事件。 (由 QStreamable 定義。)
公用擴充方法 LeftAntiJoin<TLeft, TRight, TKey>(IQStreamable<TRight>, Expression<Func<TLeft, TKey>>, Expression<Func<TRight, TKey>>) 已多載。 當 [左方] 事件與任何比對的 [右方] 事件 (根據索引鍵來比對事件) 不一致時,就會傳回左方事件。 (由 QStreamable 定義。)
公用擴充方法 Multicast<TSource>(Expression<Func<IQStreamable<TSource>, IRemoteStreamableBinding>>) 已多載。 根據給定的來源定義可以資料流方式處理的繫結。 (由 RemoteProvider 定義。)
公用擴充方法 Multicast<TSource, TResult>(Expression<Func<IQStreamable<TSource>, IQStreamable<TResult>>>) 已多載。 多點傳送運算子。 (由 QStreamable 定義。)
公用擴充方法 Select<TSource, TResult> 投射運算子。 (由 QStreamable 定義。)
公用擴充方法 SelectMany<TLeft, TRight, TResult> 交叉聯結運算子。 (由 QStreamable 定義。)
公用擴充方法 ShiftEventTime<TPayload> 將事件移位 [shiftSelector] 參數所指定的位移數。 (由 QStreamable 定義。)
公用擴充方法 SnapshotWindow<TPayload> 根據快照集產生視窗型資料流。視窗是由 [來源] 中的事件界限所定義。 (由 QStreamable 定義。)
公用擴充方法 ToEdgeEnumerable<TPayload> 將暫時資料流轉換成序列。 (由 RemoteProvider 定義。)
公用擴充方法 ToEdgeObservable<TPayload> 將暫時資料流轉換成序列。 (由 RemoteProvider 定義。)
公用擴充方法 ToEnumerable<TPayload> 將暫時資料流轉換成序列。 (由 RemoteProvider 定義。)
公用擴充方法 ToIntervalEnumerable<TPayload> 將暫時資料流轉換成序列。 (由 RemoteProvider 定義。)
公用擴充方法 ToIntervalObservable<TPayload> 將暫時資料流轉換成序列。 (由 RemoteProvider 定義。)
公用擴充方法 ToObservable<TPayload> 將暫時資料流轉換成序列。 (由 RemoteProvider 定義。)
公用擴充方法 ToPointEnumerable<TPayload> 將暫時資料流轉換成序列。 (由 RemoteProvider 定義。)
公用擴充方法 ToPointEventStream<TPayload> 將輸入資料流中的事件轉換為點事件。 (由 QStreamable 定義。)
公用擴充方法 ToPointObservable<TPayload> 將暫時資料流轉換成序列。 (由 RemoteProvider 定義。)
公用擴充方法 TumblingWindow<TPayload>(TimeSpan) 已多載。 根據視窗定義產生視窗型資料流。 (由 QStreamable 定義。)
公用擴充方法 TumblingWindow<TPayload>(TimeSpan, DateTime) 已多載。 根據視窗定義產生視窗型資料流。 (由 QStreamable 定義。)
公用擴充方法 Union<TPayload> 等位運算子。 (由 QStreamable 定義。)
公用擴充方法 Where<TPayload> 選取運算子。 (由 QStreamable 定義。)

上層

請參閱

參考

IQStreamable<TPayload> 介面

Microsoft.ComplexEventProcessing.Linq 命名空間