Streamable.Join Method

Definition

Namespace:

Microsoft.StreamProcessing

Assembly:

Microsoft.StreamProcessing.dll

Overloads

Join<TKey,TLeft,TRight,TJoinKey,TResult>(IStreamable<TKey,TLeft>, IStreamable<TKey,TRight>, Expression<Func<TLeft,TJoinKey>>, Expression<Func<TRight, TJoinKey>>, Expression<Func<TLeft,TRight,TResult>>)	Performs an equijoin between 2 streams where the join key is of type TJoinKey and selectors are passed to extract join keys from payloads
Join<TKey,TLeft,TRight,TJoinKey,TResult>(IStreamable<TKey,TLeft>, IStreamable<TKey,TRight>, Expression<Func<TLeft,TJoinKey>>, Expression<Func<TRight, TJoinKey>>, Expression<Func<TLeft,TRight,TResult>>, OperationalHint)	Performs an equijoin between 2 streams where the join key is of type TJoinKey and selectors are passed to extract join keys from payloads
Join<TKey,TLeft,TRight,TJoinKey,TResult>(IStreamable<TKey,TLeft>, IStreamable<TKey,TRight>, Expression<Func<TLeft,TJoinKey>>, Expression<Func<TRight, TJoinKey>>, Expression<Func<TLeft,TRight,TResult>>, Int64, OperationalHint)	Performs an equijoin between 2 streams where the join key is of type TJoinKey and selectors are passed to extract join keys from payloads
Join<TKey,TLeft,TRight,TResult>(IStreamable<TKey,TLeft>, IStreamable<TKey,TRight>, Expression<Func<TLeft,TRight,TResult>>)	Performs a cross-product between 2 streams
Join<TKey,TLeft,TRight,TResult>(IStreamable<TKey,TLeft>, IStreamable<TKey,TRight>, Expression<Func<TLeft,TRight,TResult>>, Int64)	Performs a cross-product between 2 streams

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

Performs an equijoin between 2 streams where the join key is of type TJoinKey and selectors are passed to extract join keys from payloads

public static Microsoft.StreamProcessing.IStreamable<TKey,TResult> Join<TKey,TLeft,TRight,TJoinKey,TResult> (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, System.Linq.Expressions.Expression<Func<TLeft,TRight,TResult>> resultSelector);

static member Join : Microsoft.StreamProcessing.IStreamable<'Key, 'Left> * Microsoft.StreamProcessing.IStreamable<'Key, 'Right> * System.Linq.Expressions.Expression<Func<'Left, 'JoinKey>> * System.Linq.Expressions.Expression<Func<'Right, 'JoinKey>> * System.Linq.Expressions.Expression<Func<'Left, 'Right, 'Result>> -> Microsoft.StreamProcessing.IStreamable<'Key, 'Result>

<Extension()>
Public Function Join(Of TKey, TLeft, TRight, TJoinKey, TResult) (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)), resultSelector As Expression(Of Func(Of TLeft, TRight, TResult))) As IStreamable(Of TKey, TResult)

Type Parameters

TKey

The key type for the inputs.

TLeft

The type of the left input.

TRight

The type of the right input.

TJoinKey

The type of the join condition.

TResult

The type of the output of the join.

Parameters

left

IStreamable<TKey,TLeft>

The left input to the join operation.

right

IStreamable<TKey,TRight>

The right input to the join operation.

leftKeySelector

Expression<Func<TLeft,TJoinKey>>

An expression that specifies the left half of the join condition.

rightKeySelector

Expression<Func<TRight,TJoinKey>>

An expression that specifies the right half of the join condition.

resultSelector

Expression<Func<TLeft,TRight,TResult>>

An expression that describes how to create result instances.

Returns

IStreamable<TKey,TResult>

Join<TKey,TLeft,TRight,TJoinKey,TResult>(IStreamable<TKey,TLeft>, IStreamable<TKey,TRight>, Expression<Func<TLeft,TJoinKey>>, Expression<Func<TRight, TJoinKey>>, Expression<Func<TLeft,TRight,TResult>>, OperationalHint)

Performs an equijoin between 2 streams where the join key is of type TJoinKey and selectors are passed to extract join keys from payloads

public static Microsoft.StreamProcessing.IStreamable<TKey,TResult> Join<TKey,TLeft,TRight,TJoinKey,TResult> (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, System.Linq.Expressions.Expression<Func<TLeft,TRight,TResult>> resultSelector, Microsoft.StreamProcessing.OperationalHint joinOptions);

static member Join : Microsoft.StreamProcessing.IStreamable<'Key, 'Left> * Microsoft.StreamProcessing.IStreamable<'Key, 'Right> * System.Linq.Expressions.Expression<Func<'Left, 'JoinKey>> * System.Linq.Expressions.Expression<Func<'Right, 'JoinKey>> * System.Linq.Expressions.Expression<Func<'Left, 'Right, 'Result>> * Microsoft.StreamProcessing.OperationalHint -> Microsoft.StreamProcessing.IStreamable<'Key, 'Result>

<Extension()>
Public Function Join(Of TKey, TLeft, TRight, TJoinKey, TResult) (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)), resultSelector As Expression(Of Func(Of TLeft, TRight, TResult)), joinOptions As OperationalHint) As IStreamable(Of TKey, TResult)

Type Parameters

TKey

The key type for the inputs.

TLeft

The type of the left input.

TRight

The type of the right input.

TJoinKey

The type of the join condition.

TResult

The type of the output of the join.

Parameters

left

IStreamable<TKey,TLeft>

The left input to the join operation.

right

IStreamable<TKey,TRight>

The right input to the join operation.

leftKeySelector

Expression<Func<TLeft,TJoinKey>>

An expression that specifies the left half of the join condition.

rightKeySelector

Expression<Func<TRight,TJoinKey>>

An expression that specifies the right half of the join condition.

resultSelector

Expression<Func<TLeft,TRight,TResult>>

An expression that describes how to create result instances.

joinOptions

OperationalHint

A hint to the query processor as to the shape of the input data.

Returns

IStreamable<TKey,TResult>

Join<TKey,TLeft,TRight,TJoinKey,TResult>(IStreamable<TKey,TLeft>, IStreamable<TKey,TRight>, Expression<Func<TLeft,TJoinKey>>, Expression<Func<TRight, TJoinKey>>, Expression<Func<TLeft,TRight,TResult>>, Int64, OperationalHint)

Performs an equijoin between 2 streams where the join key is of type TJoinKey and selectors are passed to extract join keys from payloads

public static Microsoft.StreamProcessing.IStreamable<TKey,TResult> Join<TKey,TLeft,TRight,TJoinKey,TResult> (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, System.Linq.Expressions.Expression<Func<TLeft,TRight,TResult>> resultSelector, long tolerance, Microsoft.StreamProcessing.OperationalHint joinOptions = Microsoft.StreamProcessing.OperationalHint.None);

static member Join : Microsoft.StreamProcessing.IStreamable<'Key, 'Left> * Microsoft.StreamProcessing.IStreamable<'Key, 'Right> * System.Linq.Expressions.Expression<Func<'Left, 'JoinKey>> * System.Linq.Expressions.Expression<Func<'Right, 'JoinKey>> * System.Linq.Expressions.Expression<Func<'Left, 'Right, 'Result>> * int64 * Microsoft.StreamProcessing.OperationalHint -> Microsoft.StreamProcessing.IStreamable<'Key, 'Result>

<Extension()>
Public Function Join(Of TKey, TLeft, TRight, TJoinKey, TResult) (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)), resultSelector As Expression(Of Func(Of TLeft, TRight, TResult)), tolerance As Long, Optional joinOptions As OperationalHint = Microsoft.StreamProcessing.OperationalHint.None) As IStreamable(Of TKey, TResult)

Type Parameters

TKey

The key type for the inputs.

TLeft

The type of the left input.

TRight

The type of the right input.

TJoinKey

The type of the join condition.

TResult

The type of the output of the join.

Parameters

left

IStreamable<TKey,TLeft>

The left input to the join operation.

right

IStreamable<TKey,TRight>

The right input to the join operation.

leftKeySelector

Expression<Func<TLeft,TJoinKey>>

An expression that specifies the left half of the join condition.

rightKeySelector

Expression<Func<TRight,TJoinKey>>

An expression that specifies the right half of the join condition.

resultSelector

Expression<Func<TLeft,TRight,TResult>>

An expression that describes how to create result instances.

tolerance

Int64

A tolerance window to be applied to each side of the join input.

joinOptions

OperationalHint

Additional parameter that specifies more information about the join.

Returns

IStreamable<TKey,TResult>

Join<TKey,TLeft,TRight,TResult>(IStreamable<TKey,TLeft>, IStreamable<TKey,TRight>, Expression<Func<TLeft,TRight,TResult>>)

Performs a cross-product between 2 streams

public static Microsoft.StreamProcessing.IStreamable<TKey,TResult> Join<TKey,TLeft,TRight,TResult> (this Microsoft.StreamProcessing.IStreamable<TKey,TLeft> left, Microsoft.StreamProcessing.IStreamable<TKey,TRight> right, System.Linq.Expressions.Expression<Func<TLeft,TRight,TResult>> resultSelector);

static member Join : Microsoft.StreamProcessing.IStreamable<'Key, 'Left> * Microsoft.StreamProcessing.IStreamable<'Key, 'Right> * System.Linq.Expressions.Expression<Func<'Left, 'Right, 'Result>> -> Microsoft.StreamProcessing.IStreamable<'Key, 'Result>

<Extension()>
Public Function Join(Of TKey, TLeft, TRight, TResult) (left As IStreamable(Of TKey, TLeft), right As IStreamable(Of TKey, TRight), resultSelector As Expression(Of Func(Of TLeft, TRight, TResult))) As IStreamable(Of TKey, TResult)

Type Parameters

TKey

TLeft

TRight

TResult

Parameters

left

IStreamable<TKey,TLeft>

right

IStreamable<TKey,TRight>

resultSelector

Expression<Func<TLeft,TRight,TResult>>

Returns

IStreamable<TKey,TResult>

Join<TKey,TLeft,TRight,TResult>(IStreamable<TKey,TLeft>, IStreamable<TKey,TRight>, Expression<Func<TLeft,TRight,TResult>>, Int64)

Performs a cross-product between 2 streams

public static Microsoft.StreamProcessing.IStreamable<TKey,TResult> Join<TKey,TLeft,TRight,TResult> (this Microsoft.StreamProcessing.IStreamable<TKey,TLeft> left, Microsoft.StreamProcessing.IStreamable<TKey,TRight> right, System.Linq.Expressions.Expression<Func<TLeft,TRight,TResult>> resultSelector, long tolerance);

static member Join : Microsoft.StreamProcessing.IStreamable<'Key, 'Left> * Microsoft.StreamProcessing.IStreamable<'Key, 'Right> * System.Linq.Expressions.Expression<Func<'Left, 'Right, 'Result>> * int64 -> Microsoft.StreamProcessing.IStreamable<'Key, 'Result>

<Extension()>
Public Function Join(Of TKey, TLeft, TRight, TResult) (left As IStreamable(Of TKey, TLeft), right As IStreamable(Of TKey, TRight), resultSelector As Expression(Of Func(Of TLeft, TRight, TResult)), tolerance As Long) As IStreamable(Of TKey, TResult)

Type Parameters

TKey

TLeft

TRight

TResult

Parameters

left

IStreamable<TKey,TLeft>

right

IStreamable<TKey,TRight>

resultSelector

Expression<Func<TLeft,TRight,TResult>>

tolerance

Int64

Returns

IStreamable<TKey,TResult>