Streamable.Shard<TPayload> 方法

參考

定義

命名空間:: Microsoft.StreamProcessing.Sharding

組件:: Microsoft.StreamProcessing.dll

重要

部分資訊涉及發行前產品，在發行之前可能會有大幅修改。 Microsoft 對此處提供的資訊，不做任何明確或隱含的瑕疵擔保。

將可串流化分區

public static Microsoft.StreamProcessing.Sharding.IShardedStreamable<Microsoft.StreamProcessing.Empty,TPayload> Shard<TPayload>(this Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.Empty,TPayload> source, int shardArity = -1);

static member Shard : Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.Empty, 'Payload> * int -> Microsoft.StreamProcessing.Sharding.IShardedStreamable<Microsoft.StreamProcessing.Empty, 'Payload>

<Extension()>
Public Function Shard(Of TPayload) (source As IStreamable(Of Empty, TPayload), Optional shardArity As Integer = -1) As IShardedStreamable(Of Empty, TPayload)

類型參數

TPayload

事件承載類型

參數

source: IStreamable<Empty,TPayload>

要分區的資料流程

shardArity: Int32

要建立的分區數目

傳回

IShardedStreamable<Empty,TPayload>

跨 shardArity 分區的分區資料流程

適用於