WrapPartitionedStream< TLeftKey, TRightKey >()

override void System.Linq.Parallel.JoinQueryOperator< 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 29 of file JoinQueryOperator.cs.

    {
        if (base.LeftChild.OutputOrdered)
        {
            if (base.LeftChild.OrdinalIndexState.IsWorseThan(OrdinalIndexState.Increasing))
            {
                PartitionedStream<TLeftInput, int> partitionedStream = QueryOperator<TLeftInput>.ExecuteAndCollectResults(leftStream, leftStream.PartitionCount, base.OutputOrdered, preferStriping, settings).GetPartitionedStream();
                WrapPartitionedStreamHelper(ExchangeUtilities.HashRepartitionOrdered(partitionedStream, _leftKeySelector, _keyComparer, null, settings.CancellationState.MergedCancellationToken), rightStream, outputRecipient, settings.CancellationState.MergedCancellationToken);
            }
            else
            {
                WrapPartitionedStreamHelper(ExchangeUtilities.HashRepartitionOrdered(leftStream, _leftKeySelector, _keyComparer, null, settings.CancellationState.MergedCancellationToken), rightStream, outputRecipient, settings.CancellationState.MergedCancellationToken);
            }
        }
        else
        {
            WrapPartitionedStreamHelper(ExchangeUtilities.HashRepartition(leftStream, _leftKeySelector, _keyComparer, null, settings.CancellationState.MergedCancellationToken), rightStream, outputRecipient, settings.CancellationState.MergedCancellationToken);
        }
    }

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