Streamable.AlterEventLifetime Method

Definition

Overloads

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

Changes the Vs and Ve of each event.

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

Changes the Vs and Ve of each event according to the startTimeSelector, and the durationSelector, which is a function of start and end times

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

Changes the Vs and Ve of each event according to the startTimeSelector, and the durationSelector, which is a function of start time

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

Changes the Vs and Ve of each event.

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

Type Parameters

TKey

Key type of the stream

TPayload

Data type of the stream

Parameters

source
IStreamable<TKey,TPayload>

source stream

startTimeSelector
Expression<Func<Int64,Int64>>

Function which recomputes the event start time

duration
Int64

Amount to alter the durations by

Returns

The altered stream

Applies to

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

Changes the Vs and Ve of each event according to the startTimeSelector, and the durationSelector, which is a function of start and end times

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

Type Parameters

TKey
TPayload

Parameters

source
IStreamable<TKey,TPayload>

Source stream

startTimeSelector
Expression<Func<Int64,Int64>>

Function which recomputes the event start time

durationSelector
Expression<Func<Int64,Int64,Int64>>

Function which recomputes the event duration

Returns

Applies to

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

Changes the Vs and Ve of each event according to the startTimeSelector, and the durationSelector, which is a function of start time

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

Type Parameters

TKey
TPayload

Parameters

source
IStreamable<TKey,TPayload>

Source stream

startTimeSelector
Expression<Func<Int64,Int64>>

Function which recomputes the event start time

durationSelector
Expression<Func<Int64,Int64>>

Function which recomputes the event duration

Returns

Applies to