Streamable.ClipEventDuration Method

Definition

Overloads

ClipEventDuration<TKey,TLeft,TRight,TJoinKey>(IStreamable<TKey, TLeft>, IStreamable<TKey,TRight>, Expression<Func<TLeft,TJoinKey>>, Expression<Func<TRight,TJoinKey>>)

Passes a truncated version of each event on the left, where the left event is truncated by the first event on the right whose Vs occurs after the event on the left, whose join condition is met, and where the keys for both streams match. A fast join key comparer is passed in for efficiency.

ClipEventDuration<TKey,TPayload,TClip>(IStreamable<TKey,TPayload>, IStreamable<TKey,TClip>)

Passes a truncated version of each event on the left, where the left event is truncated by the first event on the right whose Vs occurs after the event on the left. There is no restriction on join condition.

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

Passes a truncated version of each event, where the event is truncated by a maximum event length.

ClipEventDuration<TKey,TLeft,TRight,TJoinKey>(IStreamable<TKey, TLeft>, IStreamable<TKey,TRight>, Expression<Func<TLeft,TJoinKey>>, Expression<Func<TRight,TJoinKey>>)

Passes a truncated version of each event on the left, where the left event is truncated by the first event on the right whose Vs occurs after the event on the left, whose join condition is met, and where the keys for both streams match. A fast join key comparer is passed in for efficiency.

public static Microsoft.StreamProcessing.IStreamable<TKey,TLeft> ClipEventDuration<TKey,TLeft,TRight,TJoinKey> (this Microsoft.StreamProcessing.IStreamable<TKey,TLeft> left, Microsoft.StreamProcessing.IStreamable<TKey,TRight> right, System.Linq.Expressions.Expression<Func<TLeft,TJoinKey>> leftKeySelector, System.Linq.Expressions.Expression<Func<TRight,TJoinKey>> rightKeySelector);
static member ClipEventDuration : Microsoft.StreamProcessing.IStreamable<'Key, 'Left> * Microsoft.StreamProcessing.IStreamable<'Key, 'Right> * System.Linq.Expressions.Expression<Func<'Left, 'JoinKey>> * System.Linq.Expressions.Expression<Func<'Right, 'JoinKey>> -> Microsoft.StreamProcessing.IStreamable<'Key, 'Left>
<Extension()>
Public Function ClipEventDuration(Of TKey, TLeft, TRight, TJoinKey) (left As IStreamable(Of TKey, TLeft), right As IStreamable(Of TKey, TRight), leftKeySelector As Expression(Of Func(Of TLeft, TJoinKey)), rightKeySelector As Expression(Of Func(Of TRight, TJoinKey))) As IStreamable(Of TKey, TLeft)

Type Parameters

TKey
TLeft
TRight
TJoinKey

Parameters

left
IStreamable<TKey,TLeft>
right
IStreamable<TKey,TRight>
leftKeySelector
Expression<Func<TLeft,TJoinKey>>
rightKeySelector
Expression<Func<TRight,TJoinKey>>

Returns

IStreamable<TKey,TLeft>

Applies to

ClipEventDuration<TKey,TPayload,TClip>(IStreamable<TKey,TPayload>, IStreamable<TKey,TClip>)

Passes a truncated version of each event on the left, where the left event is truncated by the first event on the right whose Vs occurs after the event on the left. There is no restriction on join condition.

public static Microsoft.StreamProcessing.IStreamable<TKey,TPayload> ClipEventDuration<TKey,TPayload,TClip> (this Microsoft.StreamProcessing.IStreamable<TKey,TPayload> source, Microsoft.StreamProcessing.IStreamable<TKey,TClip> clip);
static member ClipEventDuration : Microsoft.StreamProcessing.IStreamable<'Key, 'Payload> * Microsoft.StreamProcessing.IStreamable<'Key, 'Clip> -> Microsoft.StreamProcessing.IStreamable<'Key, 'Payload>
<Extension()>
Public Function ClipEventDuration(Of TKey, TPayload, TClip) (source As IStreamable(Of TKey, TPayload), clip As IStreamable(Of TKey, TClip)) As IStreamable(Of TKey, TPayload)

Type Parameters

TKey
TPayload
TClip

Parameters

clip
IStreamable<TKey,TClip>

Returns

Applies to

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

Passes a truncated version of each event, where the event is truncated by a maximum event length.

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

Type Parameters

TKey
TPayload

Parameters

limit
Int64

Returns

Applies to