Streamable.HoppingWindowLifetime<TKey,TPayload> Method
Definition
Important
Some information relates to prerelease product that may be substantially modified before it’s released. Microsoft makes no warranties, express or implied, with respect to the information provided here.
Adjusts the lifetime of incoming events to implement, when used in combination with aggregates, hopping windows. In this implementation each incoming event results in a single outgoing event, which means that subsequent aggregates only produce output when the input changes. For instance, if a single point event is received and the windowSize, period, and offset are 100, 2, and 0 respectively, a single aggregate output is produced with a lifetime of 100 ticks.
public static Microsoft.StreamProcessing.IStreamable<TKey,TPayload> HoppingWindowLifetime<TKey,TPayload> (this Microsoft.StreamProcessing.IStreamable<TKey,TPayload> source, long windowSize, long period, long offset = 0);static member HoppingWindowLifetime : Microsoft.StreamProcessing.IStreamable<'Key, 'Payload> * int64 * int64 * int64 -> Microsoft.StreamProcessing.IStreamable<'Key, 'Payload><Extension()>
Public Function HoppingWindowLifetime(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