Streamable.AlterEventDuration Method

Definition

Overloads

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

Changes the Ve of each event according to the duration provided

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

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

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

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

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

Changes the Ve of each event according to the duration provided

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

Type Parameters

TKey
TPayload

Parameters

source
IStreamable<TKey,TPayload>

Source stream

duration
Int64

Returns

Applies to

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

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

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

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

Function which recomputes the event duration

Returns

Applies to

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

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

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

Type Parameters

TKey
TPayload

Parameters

source
IStreamable<TKey,TPayload>

Source stream

durationSelector
Expression<Func<Int64,Int64>>

Function which recomputes the event duration

Returns

Applies to