WrapPartitionedStreamHelper< TLeftKey, TRightKey >()

void System.Linq.Parallel.JoinQueryOperator< TLeftInput, TRightInput, TKey, TOutput >.WrapPartitionedStreamHelper< TLeftKey, TRightKey > ( PartitionedStream< Pair< TLeftInput, TKey >, TLeftKey > leftHashStream, PartitionedStream< TRightInput, TRightKey > rightPartitionedStream, IPartitionedStreamRecipient< TOutput > outputRecipient, CancellationToken cancellationToken )

inlineprivate

Definition at line 49 of file JoinQueryOperator.cs.

    {
        if (base.RightChild.OutputOrdered && base.LeftChild.OutputOrdered)
        {
            PairOutputKeyBuilder<TLeftKey, TRightKey> outputKeyBuilder = new PairOutputKeyBuilder<TLeftKey, TRightKey>();
            IComparer<Pair<TLeftKey, TRightKey>> outputKeyComparer = new PairComparer<TLeftKey, TRightKey>(leftHashStream.KeyComparer, rightPartitionedStream.KeyComparer);
            WrapPartitionedStreamHelper(leftHashStream, ExchangeUtilities.HashRepartitionOrdered(rightPartitionedStream, _rightKeySelector, _keyComparer, null, cancellationToken), outputKeyBuilder, outputKeyComparer, outputRecipient, cancellationToken);
        }
        else
        {
            LeftKeyOutputKeyBuilder<TLeftKey, int> outputKeyBuilder2 = new LeftKeyOutputKeyBuilder<TLeftKey, int>();
            WrapPartitionedStreamHelper(leftHashStream, ExchangeUtilities.HashRepartition(rightPartitionedStream, _rightKeySelector, _keyComparer, null, cancellationToken), outputKeyBuilder2, leftHashStream.KeyComparer, outputRecipient, cancellationToken);
        }
    }

References System.Linq.Parallel.JoinQueryOperator< TLeftInput, TRightInput, TKey, TOutput >._keyComparer, System.Linq.Parallel.JoinQueryOperator< TLeftInput, TRightInput, TKey, TOutput >._rightKeySelector, and System.cancellationToken.