共用方式為

Streamable.RegisterPartitionedArrayInput 方法

  • 參考

定義

命名空間:
Microsoft.StreamProcessing
組件:
Microsoft.StreamProcessing.dll
組件:
Microsoft.StreamProcessing.dll

多載

RegisterPartitionedArrayInput<TPartitionKey,TPayload>(QueryContainer, IObservable<ArraySegment<TPayload>>, Expression<Func<TPayload, TPartitionKey>>, Expression<Func<TPayload,Int64>>, OnCompletedPolicy, String)

使用分割區索引鍵，將一連串的資料元素轉換成僅限 IStreamable 的 start-edge。 完成原則會指定產生的資料流程完成時要執行的動作。 雜亂原則會指定使用順序錯亂事件所要執行的動作。 標點符號原則會指定是否和如何建立和插入標點符號
至產生的資料流程。 由於標點符號會強制輸出，因此這會公開輸送量/延遲取捨。
RegisterPartitionedArrayInput<TPartitionKey,TPayload>(QueryContainer, IObservable<ArraySegment<TPayload>>, Expression<Func<TPayload, TPartitionKey>>, Expression<Func<TPayload,Int64>>, Expression<Func<TPayload, Int64>>, OnCompletedPolicy, String)

使用資料分割索引鍵，將一連串的資料元素轉換成 IStreamable、間隔和開始邊緣。 完成原則會指定產生的資料流程完成時要執行的動作。 雜亂原則會指定使用順序錯亂事件所要執行的動作。 標點符號原則會指定是否和如何建立和插入標點符號
至產生的資料流程。 由於標點符號會強制輸出，因此這會公開輸送量/延遲取捨。

RegisterPartitionedArrayInput<TPartitionKey,TPayload>(QueryContainer, IObservable<ArraySegment<TPayload>>, Expression<Func<TPayload, TPartitionKey>>, Expression<Func<TPayload,Int64>>, OnCompletedPolicy, String)

使用分割區索引鍵，將一連串的資料元素轉換成僅限 IStreamable 的 start-edge。 完成原則會指定產生的資料流程完成時要執行的動作。 雜亂原則會指定使用順序錯亂事件所要執行的動作。 標點符號原則會指定是否和如何建立和插入標點符號
至產生的資料流程。 由於標點符號會強制輸出，因此這會公開輸送量/延遲取捨。

public static Microsoft.StreamProcessing.IPartitionedIngressStreamable<TPartitionKey,TPayload> RegisterPartitionedArrayInput<TPartitionKey,TPayload>(this Microsoft.StreamProcessing.QueryContainer container, IObservable<ArraySegment<TPayload>> streamEvents, System.Linq.Expressions.Expression<Func<TPayload,TPartitionKey>> partitionExtractor, System.Linq.Expressions.Expression<Func<TPayload,long>> startEdgeExtractor, Microsoft.StreamProcessing.OnCompletedPolicy onCompletedPolicy, string identifier = null);
static member RegisterPartitionedArrayInput : Microsoft.StreamProcessing.QueryContainer * IObservable<ArraySegment<'Payload>> * System.Linq.Expressions.Expression<Func<'Payload, 'PartitionKey>> * System.Linq.Expressions.Expression<Func<'Payload, int64>> * Microsoft.StreamProcessing.OnCompletedPolicy * string -> Microsoft.StreamProcessing.IPartitionedIngressStreamable<'PartitionKey, 'Payload>

類型參數

TPartitionKey

資料流程的資料分割索引鍵類型。

TPayload

資料流程的資料類型。

參數

container
QueryContainer

要註冊輸入點的查詢容器。

streamEvents
IObservable<ArraySegment<TPayload>>

用戶端所建立的資料流程事件序列。

partitionExtractor
Expression<Func<TPayload,TPartitionKey>>

描述如何解譯每個資料值之資料分割識別碼的 expresion。

startEdgeExtractor
Expression<Func<TPayload,Int64>>

描述如何解譯每個資料值的開始時間的 expresion。

onCompletedPolicy
OnCompletedPolicy

如何處理資料流程完成。

identifier
String

如果提供，則為唯一的名稱，用來識別查詢中的輸入點。

傳回

IPartitionedIngressStreamable<TPartitionKey,TPayload>

可用於查詢的 IStreamable。

例外狀況

IngressException

如果遇到順序錯亂的資料流程事件，則會擲回例外狀況。 此外，如果任何承載為 Null，則會擲回例外狀況。

適用於

RegisterPartitionedArrayInput<TPartitionKey,TPayload>(QueryContainer, IObservable<ArraySegment<TPayload>>, Expression<Func<TPayload, TPartitionKey>>, Expression<Func<TPayload,Int64>>, Expression<Func<TPayload, Int64>>, OnCompletedPolicy, String)

使用資料分割索引鍵，將一連串的資料元素轉換成 IStreamable、間隔和開始邊緣。 完成原則會指定產生的資料流程完成時要執行的動作。 雜亂原則會指定使用順序錯亂事件所要執行的動作。 標點符號原則會指定是否和如何建立和插入標點符號
至產生的資料流程。 由於標點符號會強制輸出，因此這會公開輸送量/延遲取捨。

public static Microsoft.StreamProcessing.IPartitionedIngressStreamable<TPartitionKey,TPayload> RegisterPartitionedArrayInput<TPartitionKey,TPayload>(this Microsoft.StreamProcessing.QueryContainer container, IObservable<ArraySegment<TPayload>> streamEvents, System.Linq.Expressions.Expression<Func<TPayload,TPartitionKey>> partitionExtractor, System.Linq.Expressions.Expression<Func<TPayload,long>> startEdgeExtractor, System.Linq.Expressions.Expression<Func<TPayload,long>> endEdgeExtractor, Microsoft.StreamProcessing.OnCompletedPolicy onCompletedPolicy, string identifier = null);
static member RegisterPartitionedArrayInput : Microsoft.StreamProcessing.QueryContainer * IObservable<ArraySegment<'Payload>> * System.Linq.Expressions.Expression<Func<'Payload, 'PartitionKey>> * System.Linq.Expressions.Expression<Func<'Payload, int64>> * System.Linq.Expressions.Expression<Func<'Payload, int64>> * Microsoft.StreamProcessing.OnCompletedPolicy * string -> Microsoft.StreamProcessing.IPartitionedIngressStreamable<'PartitionKey, 'Payload>

類型參數

TPartitionKey

資料流程的資料分割索引鍵類型。

TPayload

資料流程的資料類型。

參數

container
QueryContainer

要註冊輸入點的查詢容器。

streamEvents
IObservable<ArraySegment<TPayload>>

用戶端所建立的資料流程事件序列。

partitionExtractor
Expression<Func<TPayload,TPartitionKey>>

描述如何解譯每個資料值之資料分割識別碼的 expresion。

startEdgeExtractor
Expression<Func<TPayload,Int64>>

描述如何解譯每個資料值的開始時間的 expresion。

endEdgeExtractor
Expression<Func<TPayload,Int64>>

描述如何解譯每個資料值結束時間的 expresion。 傳回 StreamEvent.InfinitySyncTime，表示沒有結束時間的事件。

onCompletedPolicy
OnCompletedPolicy

如何處理資料流程完成。

identifier
String

如果提供，則為唯一的名稱，用來識別查詢中的輸入點。

傳回

IPartitionedIngressStreamable<TPartitionKey,TPayload>

可用於查詢的 IStreamable。

例外狀況

IngressException

如果遇到順序錯亂的資料流程事件，則會擲回例外狀況。 此外，如果任何承載為 Null，則會擲回例外狀況。

適用於