共用方式為


Microsoft.StreamProcessing 命名空間

類別

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 事件

介面

IAbstractPattern<TKey,TPayload,TRegister,TAccumulator>

介面只是公用的,可提供 CLR 強型別 - 實例應該只在內部建立。 請勿直接使用。

IAbstractPatternRoot<TKey,TPayload,TRegister,TAccumulator>

介面只是公用的,可提供 CLR 強型別 - 實例應該只在內部建立。 請勿直接使用。

IComparerExpression<T>

運算式的包裝函式介面,可比較指定型別的兩個值。

IConnectableStreamable<TKey,TPayload>

將新的可串流輸出動態連線至現有資料流程的介面

IEqualityComparerExpression<T>

提供運算式型方法來指定相同動作 IComparer<T> 的介面:用於相等的函式,以及計算雜湊的函式。

IIngressStreamable<TKey,TPayload>

對應至查詢之輸入點之可資料流程的介面。

IMapDefinition<TMapInputLeft,TMapInputRight,TInnerKey,TReduceInput>

代表 map-reduce 函式之作業的預留位置介面

IMapDefinition<TOuterKey,TMapInputLeft,TMapInputRight,TInnerKey,TReduceInput>

代表 map-reduce 函式之作業的預留位置介面

IObservableIngressStreamable<TPayload>

對應至輸入點的可串流介面,其中輸入可能順序不足的查詢。

IPartitionedIngressStreamable<TPartitionKey,TPayload>

對應至輸入點的可串流介面,其中輸入可能順序不足的查詢。

IPassiveIngressStreamable<TKey,TPayload>

可外部觸發以讀取可用資料的被動輸入月臺介面。

IPattern<TKey,TPayload,TRegister,TAccumulator>

介面只是公用的,可提供 CLR 強型別 - 實例應該只在內部建立。 請勿直接使用。

IStreamable<TKey,TPayload>

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

列舉

AggregatePipeType

可用狀態管理演算法類型的列舉。

JoinKind

描述特定聯結查詢計劃節點中使用的聯結種類。

OperationalHint

提供提示,說明運算子應該使用的方法

PlanNodeKind

計畫節點的類型。

SortingTechnique

選擇哪些技術應該用於資料輸入,以排序任何順序不依序的資料。

StreamEventKind

資料列式 StreamEvents 的事件種類

StreamMessageKind

透過查詢傳遞的個別訊息串流訊息類型