WrapPartitionedStreamHelper< TLeftKey, TRightKey, TOutputKey >()

void System.Linq.Parallel.JoinQueryOperator< TLeftInput, TRightInput, TKey, TOutput >.WrapPartitionedStreamHelper< TLeftKey, TRightKey, TOutputKey > ( PartitionedStream< Pair< TLeftInput, TKey >, TLeftKey > leftHashStream, PartitionedStream< Pair< TRightInput, TKey >, TRightKey > rightHashStream, HashJoinOutputKeyBuilder< TLeftKey, TRightKey, TOutputKey > outputKeyBuilder, IComparer< TOutputKey > outputKeyComparer, IPartitionedStreamRecipient< TOutput > outputRecipient, CancellationToken cancellationToken )

inlineprivate

Definition at line 64 of file JoinQueryOperator.cs.

    {
        int partitionCount = leftHashStream.PartitionCount;
        PartitionedStream<TOutput, TOutputKey> partitionedStream = new PartitionedStream<TOutput, TOutputKey>(partitionCount, outputKeyComparer, OrdinalIndexState);
        for (int i = 0; i < partitionCount; i++)
        {
            JoinHashLookupBuilder<TRightInput, TRightKey, TKey> rightLookupBuilder = new JoinHashLookupBuilder<TRightInput, TRightKey, TKey>(rightHashStream[i], _keyComparer);
            partitionedStream[i] = new HashJoinQueryOperatorEnumerator<TLeftInput, TLeftKey, TRightInput, TRightKey, TKey, TOutput, TOutputKey>(leftHashStream[i], rightLookupBuilder, _resultSelector, outputKeyBuilder, cancellationToken);
        }
        outputRecipient.Receive(partitionedStream);
    }

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