Microsoft.StreamProcessing 命名空間
重要
部分資訊涉及發行前產品,在發行之前可能會有大幅修改。 Microsoft 對此處提供的資訊,不做任何明確或隱含的瑕疵擔保。
類別
| Afa |
建立 AFA 物件的擴充方法 |
| Afa<TInput,TRegister> |
較簡單的 AFA 形式,其累積器是簡單的布林值,表示模式已相符 |
| Afa<TInput,TRegister,TAccumulator> |
描述 AFA 的完整類別及其屬性。 |
| AfaPlanNode |
查詢計劃中的節點,代表所有輸入資料列的函式應用程式。 |
| AlterLifetimePlanNode |
查詢計劃中的節點,代表對使用中執行查詢中變數持續時間之事件存留期的變更。 |
| ARegex |
建立器類別,用來建立使用正則運算式介面比對資料流程資料的模式 |
| BeatPlanNode |
查詢計劃中代表將每個事件時間軸分割成相等間隔的節點。 |
| ClipByConstantPlanNode |
查詢計劃中的節點,代表執行中查詢中作用中作業 (「ClipByConstant」) 作業的存留期截斷。 |
| ColumnToRowPlanNode |
查詢計劃中的節點,代表從資料行導向資料移轉至作用中執行查詢中的資料列導向。 |
| Config |
保留所有使用者組態設定的靜態類別。 |
| DisorderPolicy |
指定如何處理順序錯亂的事件 |
| EgressPlanNode |
查詢計劃中的節點,代表使用中、執行中查詢中的資料來源。 |
| EndEdgeFreeOutputPlanNode |
查詢計劃中的節點,代表所有輸入資料列的函式應用程式。 |
| EqualityComparerExpression<T> |
提供將兩個函式包裝至 的 IEqualityComparerExpression<T> 實作。 |
| EvolvingStateEnumerable<TPayload> |
可列舉的物件,其內容可能會隨著資料流程提供其他資料而變更。 |
| ExtendLifetimePlanNode |
查詢計劃中代表執行中查詢中之存留期延伸模組 (「ExtendLifetime」) 作業的節點。 |
| FilteredWindow<TKey,TSource> |
當篩選存在時套用其他語意的 Window 衍生類別 |
| FusedPlanNode |
查詢計劃中的節點,代表使用中、執行中查詢中的資料來源。 |
| GroupedWindowPlanNode<TInput,TState,TResult> |
查詢計劃中代表群組視窗快照集作業的節點。 |
| GroupPlanNode |
表示Map-Reduce程式中的群組作業。 |
| IngressException |
資料輸入期間發生錯誤的特定例外狀況。 |
| IngressPlanNode |
查詢計劃中的節點,代表使用中、執行中查詢中的資料來源。 |
| JoinPlanNode |
查詢計劃中的節點,代表使用中、執行中查詢中的聯結作業。 |
| MulticastPlanNode |
表示資料流程中的作業,以允許多個訂閱者接收相同的訊息。 |
| OnCompletedPolicy |
指定如何在接收 OnCompleted 呼叫) 時處理查詢完成 (。 |
| OutOfOrderPartitionedStreamEvent |
靜態類別,其中包含 OutOfOrderPartitionedStreamEvent 物件的產生器方法。 |
| OutOfOrderStreamEvent |
靜態類別,其中包含 OutOfOrderStreamEvent 物件的產生器方法。 |
| PartitionedDisorderPolicy |
指定如何處理順序錯亂的事件 |
| PartitionedPeriodicPunctuationPolicy |
指定如何將標點符號插入產生的資料流程中。 因為標點符號會強制輸出,所以這會公開輸送量/延遲取捨。 |
| PartitionedStreamEvent |
不相依于泛型引數的分割資料流程事件協助程式。 |
| PeriodicPunctuationPolicy |
指定如何將標點符號插入產生的資料流程中。 因為標點符號會強制輸出,所以這會公開輸送量/延遲取捨。 |
| PlanNode |
查詢計劃中的節點,代表使用中執行中查詢中的物件。 |
| PointAtEndPlanNode |
查詢計劃中代表存留期轉換的節點,會將存留期移至執行中查詢中的單位間隔 (「PointAtEnd」) 作業。 |
| Process |
類別,表示可以檢查點的執行中查詢。 |
| Properties |
可串流擴充方法。 |
| QuantizeLifetimePlanNode |
查詢計劃中代表存留期轉換的節點,會沿著使用中、執行中查詢中的跳動界限,將開始和結束時間量化。 |
| QueryContainer |
表示資料流程查詢的容器物件。 |
| ReshapingPolicy |
指定事件在輸出時是否和如何重新調整的原則 |
| RowToColumnPlanNode |
查詢計劃中的節點,代表從資料列導向資料移轉至作用中執行查詢中的資料行導向。 |
| SelectBatchPlanNode |
查詢計劃中的節點,代表所有輸入資料列的函式應用程式。 |
| SelectManyPlanNode |
查詢計劃中代表使用中執行查詢中 SelectMany 作業的節點。 |
| SelectPlanNode |
查詢計劃中的節點,代表所有輸入資料列的函式應用程式。 |
| SessionWindowPlanNode |
查詢計劃中代表會話視窗截斷的節點, (「SessionTimeoutWindow」) 執行中查詢中的作業。 |
| SnapshotWindowPlanNode<TInput,TState,TResult> |
查詢計劃中代表批次視窗快照集作業的節點。 |
| SprayPlanNode |
表示Map-Reduce作業中的作業,會將資料噴灑到不同的節點。 |
| StitchPlanNode |
查詢計劃中代表類似事件與相鄰存留期間隔的統一節點。 |
| Streamable |
可串流擴充方法。 |
| StreamCache<TKey,TPayload> |
針對後續反復專案,以高效能且易讀的方式儲存完整的串流 |
| StreamEvent |
不相依于泛型引數的串流事件協助程式。 |
| StreamProcessingException |
表示 中某個位置的使用者例外狀況 |
| StreamProperties<TKey,TPayload> |
保存資料流程之資料流程屬性集的類別 |
| StreamScheduler |
類別,可透過Microsoft.StreamProcessing.Config設定 Trill (的排程策略。StreamScheduler) |
| TemporalSortPlanNode |
查詢計劃中的節點,代表作用中、執行中查詢中時間戳記) 作業的時態排序 (。 |
| TimelinePolicy |
指定如何將單調增加的時態性元件指派給內部範本資料。 |
| UngroupPlanNode |
表示Map-Reduce程式中的解除群組作業。 |
| UnionPlanNode |
表示目前的節點是聯集作業。 |
| UserDefinedPlanNode<TKey,TSource,TResult> |
查詢計劃中代表程式庫外部所定義的作業的節點。 |
| WherePlanNode |
查詢計劃中的節點,代表作用中、執行中查詢中) 作業的 (「where」。 |
| Window<TKey,TSource> |
類別,表示匯總作業內的視窗。 |
結構
| Empty |
類型,表示空結構,類似于其他程式庫和語言中的 Unit。 |
| OutOfOrderPartitionedStreamEvent<TKey,TPayload> |
結構,表示元組必須從資料來源調整或卸載資料輸入的時間。 |
| OutOfOrderStreamEvent<TPayload> |
結構,表示元組必須從資料來源調整或卸載資料輸入的時間。 |
| PartitionedStreamEvent<TKey,TPayload> |
表示分割的 Stream 事件 |
| StreamEvent<TPayload> |
表示未分割的 Stream 事件 |
介面
列舉
| AggregatePipeType |
可用狀態管理演算法類型的列舉。 |
| JoinKind |
描述特定聯結查詢計劃節點中使用的聯結種類。 |
| OperationalHint |
提供提示,說明運算子應該使用的方法 |
| PlanNodeKind |
計畫節點的類型。 |
| SortingTechnique |
選擇哪些技術應該用於資料輸入,以排序任何順序不依序的資料。 |
| StreamEventKind |
資料列式 StreamEvents 的事件種類 |
| StreamMessageKind |
透過查詢傳遞的個別訊息串流訊息類型 |