Share via


Streamable.QuantizeLifetime<TKey,TPayload> Method

Definition

Adjusts the lifetime of incoming events to snap the start and end time of each event to quantized boundaries. The function is similar to a hopping lifetime expression, except that all start edges are either moved earlier or stay the same, and all end edges either move later or stay the same.

public static Microsoft.StreamProcessing.IStreamable<TKey,TPayload> QuantizeLifetime<TKey,TPayload> (this Microsoft.StreamProcessing.IStreamable<TKey,TPayload> source, long windowSize, long period, long offset = 0);
static member QuantizeLifetime : Microsoft.StreamProcessing.IStreamable<'Key, 'Payload> * int64 * int64 * int64 -> Microsoft.StreamProcessing.IStreamable<'Key, 'Payload>
<Extension()>
Public Function QuantizeLifetime(Of TKey, TPayload) (source As IStreamable(Of TKey, TPayload), windowSize As Long, period As Long, Optional offset As Long = 0) As IStreamable(Of TKey, TPayload)

Type Parameters

TKey

Type of (mapping) key in the stream

TPayload

Type of payload in the stream

Parameters

source
IStreamable<TKey,TPayload>

Input stream

windowSize
Int64

Window size

period
Int64

Period (or hop size)

offset
Int64

Offset from the start of time

Returns

Result (output) stream

Applies to