WrapPartitionedStreamHelper< TLeftKey, TRightKey >() [2/2]

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

inlineprivate

Definition at line 49 of file GroupJoinQueryOperator.cs.

    {
        if (base.RightChild.OutputOrdered)
        {
            PartitionedStream<Pair<TRightInput, TKey>, TRightKey> partitionedStream = ExchangeUtilities.HashRepartitionOrdered(rightPartitionedStream, _rightKeySelector, _keyComparer, null, cancellationToken);
            HashLookupBuilder<IEnumerable<TRightInput>, Pair<bool, TRightKey>, TKey>[] array = new HashLookupBuilder<IEnumerable<TRightInput>, Pair<bool, TRightKey>, TKey>[partitionCount];
            for (int i = 0; i < partitionCount; i++)
            {
                array[i] = new OrderedGroupJoinHashLookupBuilder<TRightInput, TRightKey, TKey>(partitionedStream[i], _keyComparer, partitionedStream.KeyComparer);
            }
            WrapPartitionedStreamHelper(leftHashStream, array, CreateComparer(rightPartitionedStream.KeyComparer), outputRecipient, partitionCount, cancellationToken);
        }
        else
        {
            PartitionedStream<Pair<TRightInput, TKey>, int> partitionedStream2 = ExchangeUtilities.HashRepartition(rightPartitionedStream, _rightKeySelector, _keyComparer, null, cancellationToken);
            HashLookupBuilder<IEnumerable<TRightInput>, int, TKey>[] array2 = new HashLookupBuilder<IEnumerable<TRightInput>, int, TKey>[partitionCount];
            for (int j = 0; j < partitionCount; j++)
            {
                array2[j] = new GroupJoinHashLookupBuilder<TRightInput, int, TKey>(partitionedStream2[j], _keyComparer);
            }
            WrapPartitionedStreamHelper(leftHashStream, array2, null, outputRecipient, partitionCount, cancellationToken);
        }
    }

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