Execute< TKey >()

static MergeExecutor< TInputOutput > System.Linq.Parallel.MergeExecutor< TInputOutput >.Execute< TKey > ( PartitionedStream< TInputOutput, TKey > partitions, bool ignoreOutput, ParallelMergeOptions options, TaskScheduler taskScheduler, bool isOrdered, CancellationState cancellationState, int queryId )

inlinestaticpackage

Definition at line 16 of file MergeExecutor.cs.

    {
        MergeExecutor<TInputOutput> mergeExecutor = new MergeExecutor<TInputOutput>();
        if (isOrdered && !ignoreOutput)
        {
            if (options != ParallelMergeOptions.FullyBuffered && !partitions.OrdinalIndexState.IsWorseThan(OrdinalIndexState.Increasing))
            {
                bool autoBuffered = options == ParallelMergeOptions.AutoBuffered;
                if (partitions.PartitionCount > 1)
                {
                    mergeExecutor._mergeHelper = new OrderPreservingPipeliningMergeHelper<TInputOutput, TKey>(partitions, taskScheduler, cancellationState, autoBuffered, queryId, partitions.KeyComparer);
                }
                else
                {
                    mergeExecutor._mergeHelper = new DefaultMergeHelper<TInputOutput, TKey>(partitions, ignoreOutput: false, options, taskScheduler, cancellationState, queryId);
                }
            }
            else
            {
                mergeExecutor._mergeHelper = new OrderPreservingMergeHelper<TInputOutput, TKey>(partitions, taskScheduler, cancellationState, queryId);
            }
        }
        else
        {
            mergeExecutor._mergeHelper = new DefaultMergeHelper<TInputOutput, TKey>(partitions, ignoreOutput, options, taskScheduler, cancellationState, queryId);
        }
        mergeExecutor.Execute();
        return mergeExecutor;
    }

References System.options.