WrapPartitionedStream< TLeftKey, TRightKey >()

override void System.Linq.Parallel.GroupJoinQueryOperator< TLeftInput, TRightInput, TKey, TOutput >.WrapPartitionedStream< TLeftKey, TRightKey > ( PartitionedStream< TLeftInput, TLeftKey > leftStream, PartitionedStream< TRightInput, TRightKey > rightStream, IPartitionedStreamRecipient< TOutput > outputRecipient, bool preferStriping, QuerySettings settings )

inline

Definition at line 36 of file GroupJoinQueryOperator.cs.

    {
        int partitionCount = leftStream.PartitionCount;
        if (base.LeftChild.OutputOrdered)
        {
            WrapPartitionedStreamHelper(ExchangeUtilities.HashRepartitionOrdered(leftStream, _leftKeySelector, _keyComparer, null, settings.CancellationState.MergedCancellationToken), rightStream, outputRecipient, partitionCount, settings.CancellationState.MergedCancellationToken);
        }
        else
        {
            WrapPartitionedStreamHelper(ExchangeUtilities.HashRepartition(leftStream, _leftKeySelector, _keyComparer, null, settings.CancellationState.MergedCancellationToken), rightStream, outputRecipient, partitionCount, settings.CancellationState.MergedCancellationToken);
        }
    }

References System.Linq.Parallel.GroupJoinQueryOperator< TLeftInput, TRightInput, TKey, TOutput >._keyComparer, System.Linq.Parallel.GroupJoinQueryOperator< TLeftInput, TRightInput, TKey, TOutput >._leftKeySelector, System.Linq.Parallel.QuerySettings.CancellationState, and System.Linq.Parallel.CancellationState.MergedCancellationToken.