Streamable.TumblingWindowLifetime<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, tumbling 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 tumbleDuration and offset are 100 and 0 respectively, a single aggregate output is produced with a lifetime of 100 ticks.
public static Microsoft.StreamProcessing.IStreamable<TKey,TPayload> TumblingWindowLifetime<TKey,TPayload> (this Microsoft.StreamProcessing.IStreamable<TKey,TPayload> source, long tumbleDuration, long offset = 0);static member TumblingWindowLifetime : Microsoft.StreamProcessing.IStreamable<'Key, 'Payload> * int64 * int64 -> Microsoft.StreamProcessing.IStreamable<'Key, 'Payload><Extension()>
Public Function TumblingWindowLifetime(Of TKey, TPayload) (source As IStreamable(Of TKey, TPayload), tumbleDuration 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
- tumbleDuration
- Int64
Duration of the tumble
- offset
- Int64
Offset from the start of time
Returns
Result (output) stream