WrapPartitionedStream< TKey >() [2/2]

override void System.Linq.Parallel.DistinctQueryOperator< TInputOutput >.WrapPartitionedStream< TKey > ( PartitionedStream< TInputOutput, TKey > inputStream, IPartitionedStreamRecipient< TInputOutput > recipient, bool preferStriping, QuerySettings settings )

inlinepackage

Definition at line 133 of file DistinctQueryOperator.cs.

    {
        if (base.OutputOrdered)
        {
            WrapPartitionedStreamHelper(ExchangeUtilities.HashRepartitionOrdered<TInputOutput, NoKeyMemoizationRequired, TKey>(inputStream, null, null, _comparer, settings.CancellationState.MergedCancellationToken), recipient, settings.CancellationState.MergedCancellationToken);
        }
        else
        {
            WrapPartitionedStreamHelper(ExchangeUtilities.HashRepartition<TInputOutput, NoKeyMemoizationRequired, TKey>(inputStream, null, null, _comparer, settings.CancellationState.MergedCancellationToken), recipient, settings.CancellationState.MergedCancellationToken);
        }
    }

References System.Linq.Parallel.DistinctQueryOperator< TInputOutput >._comparer, System.Linq.Parallel.QuerySettings.CancellationState, and System.Linq.Parallel.CancellationState.MergedCancellationToken.