WrapPartitionedStream< TKey >() [2/2]

override void System.Linq.Parallel.GroupByQueryOperator< TSource, TGroupKey, TElement >.WrapPartitionedStream< TKey > ( PartitionedStream< TSource, TKey > inputStream, IPartitionedStreamRecipient< IGrouping< TGroupKey, TElement > > recipient, bool preferStriping, QuerySettings settings )

inlinepackage

Definition at line 25 of file GroupByQueryOperator.cs.

    {
        if (base.Child.OutputOrdered)
        {
            WrapPartitionedStreamHelperOrdered(ExchangeUtilities.HashRepartitionOrdered(inputStream, _keySelector, _keyComparer, null, settings.CancellationState.MergedCancellationToken), recipient, settings.CancellationState.MergedCancellationToken);
        }
        else
        {
            WrapPartitionedStreamHelper<TKey, int>(ExchangeUtilities.HashRepartition(inputStream, _keySelector, _keyComparer, null, settings.CancellationState.MergedCancellationToken), recipient, settings.CancellationState.MergedCancellationToken);
        }
    }

References System.Linq.Parallel.GroupByQueryOperator< TSource, TGroupKey, TElement >._keyComparer, System.Linq.Parallel.GroupByQueryOperator< TSource, TGroupKey, TElement >._keySelector, System.Linq.Parallel.QuerySettings.CancellationState, and System.Linq.Parallel.CancellationState.MergedCancellationToken.