Streamable.AlterEventLifetime 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.
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