Streamable.ShiftEventLifetime Method

Definition

Overloads

ShiftEventLifetime<TKey,TPayload>(IStreamable<TKey,TPayload>, Int64)

Shifts the lifetime by the specified amount of time

ShiftEventLifetime<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<Int64,Int64>>)

Shifts the lifetime by the shiftSelector, which is a function of the event start time

ShiftEventLifetime<TKey,TPayload>(IStreamable<TKey,TPayload>, Int64)

Shifts the lifetime by the specified amount of time

public static Microsoft.StreamProcessing.IStreamable<TKey,TPayload> ShiftEventLifetime<TKey,TPayload> (this Microsoft.StreamProcessing.IStreamable<TKey,TPayload> source, long shiftAmount);
static member ShiftEventLifetime : Microsoft.StreamProcessing.IStreamable<'Key, 'Payload> * int64 -> Microsoft.StreamProcessing.IStreamable<'Key, 'Payload>
<Extension()>
Public Function ShiftEventLifetime(Of TKey, TPayload) (source As IStreamable(Of TKey, TPayload), shiftAmount As Long) As IStreamable(Of TKey, TPayload)

Type Parameters

TKey
TPayload

Parameters

source
IStreamable<TKey,TPayload>

Source stream

shiftAmount
Int64

The amount to shift the Vs by

Returns

Applies to

ShiftEventLifetime<TKey,TPayload>(IStreamable<TKey,TPayload>, Expression<Func<Int64,Int64>>)

Shifts the lifetime by the shiftSelector, which is a function of the event start time

public static Microsoft.StreamProcessing.IStreamable<TKey,TPayload> ShiftEventLifetime<TKey,TPayload> (this Microsoft.StreamProcessing.IStreamable<TKey,TPayload> source, System.Linq.Expressions.Expression<Func<long,long>> shiftSelector);
static member ShiftEventLifetime : Microsoft.StreamProcessing.IStreamable<'Key, 'Payload> * System.Linq.Expressions.Expression<Func<int64, int64>> -> Microsoft.StreamProcessing.IStreamable<'Key, 'Payload>
<Extension()>
Public Function ShiftEventLifetime(Of TKey, TPayload) (source As IStreamable(Of TKey, TPayload), shiftSelector As Expression(Of Func(Of Long, Long))) As IStreamable(Of TKey, TPayload)

Type Parameters

TKey
TPayload

Parameters

source
IStreamable<TKey,TPayload>

Source stream

shiftSelector
Expression<Func<Int64,Int64>>

Function which computes the amount to shift the Vs by

Returns

Applies to