Aracılığıyla paylaş


Streamable.ReservoirSample<TPayload> Yöntem

Tanım

Akış rezervuarı örnekleme uzantısı (yalnızca ConstantDuration özelliği true olarak ayarlanmış bir akışta çalışır ve süre StreamEvent.InfinitySyncTime olarak ayarlanır; örneğin akışın yalnızca başlangıç kenarları vardır)

public static Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.Empty,TPayload> ReservoirSample<TPayload>(this Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.Empty,TPayload> source, int reservoirSize, int randomSeed = 0);
static member ReservoirSample : Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.Empty, 'Payload> * int * int -> Microsoft.StreamProcessing.IStreamable<Microsoft.StreamProcessing.Empty, 'Payload>
<Extension()>
Public Function ReservoirSample(Of TPayload) (source As IStreamable(Of Empty, TPayload), reservoirSize As Integer, Optional randomSeed As Integer = 0) As IStreamable(Of Empty, TPayload)

Tür Parametreleri

TPayload

Giriş yükü türü

Parametreler

source
IStreamable<Empty,TPayload>

Giriş akışı

reservoirSize
Int32

Rezervuarın boyutu

randomSeed
Int32

Rastgele tohum

Döndürülenler

IStreamable<Empty,TPayload>

Rezervuar örneklenmiş akış

Şunlara uygulanır