82 references to ParallelMergeOptions
System.Core (82)
System\Linq\Parallel\Merging\DefaultMergeHelper.cs (2)
49internal DefaultMergeHelper(PartitionedStream<TInputOutput, TIgnoreKey> partitions, bool ignoreOutput, ParallelMergeOptions options, 67if (options != ParallelMergeOptions.FullyBuffered)
System\Linq\Parallel\Merging\MergeExecutor.cs (10)
55PartitionedStream<TInputOutput, TKey> partitions, bool ignoreOutput, ParallelMergeOptions options, TaskScheduler taskScheduler, bool isOrdered, 60Contract.Assert(!ignoreOutput || options == ParallelMergeOptions.FullyBuffered, "@BUGBUG: pipelining w/ no output not supported -- need it?"); 65if (options != ParallelMergeOptions.FullyBuffered && !partitions.OrdinalIndexState.IsWorseThan(OrdinalIndexState.Increasing)) 67Contract.Assert(options == ParallelMergeOptions.NotBuffered || options == ParallelMergeOptions.AutoBuffered); 68bool autoBuffered = (options == ParallelMergeOptions.AutoBuffered); 147internal static AsynchronousChannel<TInputOutput>[] MakeAsynchronousChannels(int partitionCount, ParallelMergeOptions options, IntValueEvent consumerEvent, CancellationToken cancellationToken) 151Contract.Assert(options == ParallelMergeOptions.NotBuffered || options == ParallelMergeOptions.AutoBuffered); 161if (options == ParallelMergeOptions.NotBuffered)
System\Linq\Parallel\QueryOperators\AssociativeAggregationOperator.cs (1)
122using (IEnumerator<TIntermediate> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Binary\ZipQueryOperator.cs (2)
97false, ParallelMergeOptions.FullyBuffered, settings.TaskScheduler, m_leftChild.OutputOrdered, 107false, ParallelMergeOptions.FullyBuffered, settings.TaskScheduler, m_rightChild.OutputOrdered,
System\Linq\Parallel\QueryOperators\Inlined\CountAggregationOperator.cs (1)
49using (IEnumerator<int> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Inlined\DecimalAverageAggregationOperator.cs (1)
50using (IEnumerator<Pair<decimal, long>> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Inlined\DecimalMinMaxAggregationOperator.cs (1)
54using (IEnumerator<decimal> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Inlined\DecimalSumAggregationOperator.cs (1)
51using (IEnumerator<decimal> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Inlined\DoubleAverageAggregationOperator.cs (1)
49using (IEnumerator<Pair<double, long>> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Inlined\DoubleMinMaxAggregationOperator.cs (1)
59using (IEnumerator<double> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Inlined\DoubleSumAggregationOperator.cs (1)
50using (IEnumerator<double> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Inlined\FloatAverageAggregationOperator.cs (1)
49using (IEnumerator<Pair<double, long>> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Inlined\FloatMinMaxAggregationOperator.cs (1)
58using (IEnumerator<float> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Inlined\FloatSumAggregationOperator.cs (1)
51using (IEnumerator<double> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Inlined\IntAverageAggregationOperator.cs (1)
50using (IEnumerator<Pair<long, long>> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Inlined\IntMinMaxAggregationOperator.cs (1)
54using (IEnumerator<int> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Inlined\IntSumAggregationOperator.cs (1)
52using (IEnumerator<int> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Inlined\LongAverageAggregationOperator.cs (1)
50using (IEnumerator<Pair<long, long>> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Inlined\LongCountAggregationOperator.cs (1)
52using (IEnumerator<long> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Inlined\LongMinMaxAggregationOperator.cs (1)
54using (IEnumerator<long> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Inlined\LongSumAggregationOperator.cs (1)
51using (IEnumerator<long> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Inlined\NullableDecimalAverageAggregationOperator.cs (1)
47using (IEnumerator<Pair<decimal, long>> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Inlined\NullableDecimalMinMaxAggregationOperator.cs (1)
51using (IEnumerator<decimal?> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Inlined\NullableDecimalSumAggregationOperator.cs (1)
48using (IEnumerator<decimal?> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Inlined\NullableDoubleAverageAggregationOperator.cs (1)
47using (IEnumerator<Pair<double, long>> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Inlined\NullableDoubleMinMaxAggregationOperator.cs (1)
57using (IEnumerator<double?> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Inlined\NullableDoubleSumAggregationOperator.cs (1)
48using (IEnumerator<double?> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Inlined\NullableFloatAverageAggregationOperator.cs (1)
47using (IEnumerator<Pair<double, long>> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Inlined\NullableFloatMinMaxAggregationOperator.cs (1)
57using (IEnumerator<float?> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Inlined\NullableFloatSumAggregationOperator.cs (1)
48using (IEnumerator<double?> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Inlined\NullableIntAverageAggregationOperator.cs (1)
47using (IEnumerator<Pair<long, long>> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Inlined\NullableIntMinMaxAggregationOperator.cs (1)
51using (IEnumerator<int?> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Inlined\NullableIntSumAggregationOperator.cs (1)
48using (IEnumerator<int?> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Inlined\NullableLongAverageAggregationOperator.cs (1)
47using (IEnumerator<Pair<long, long>> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Inlined\NullableLongMinMaxAggregationOperator.cs (1)
51using (IEnumerator<long?> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Inlined\NullableLongSumAggregationOperator.cs (1)
48using (IEnumerator<long?> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Options\OrderingQueryOperator.cs (1)
44internal override IEnumerator<TSource> GetEnumerator(ParallelMergeOptions? mergeOptions, bool suppressOrderPreservation)
System\Linq\Parallel\QueryOperators\PartitionedStreamMerger.cs (2)
25private ParallelMergeOptions m_mergeOptions; 48internal PartitionedStreamMerger(bool forEffectMerge, ParallelMergeOptions mergeOptions, TaskScheduler taskScheduler, bool outputOrdered,
System\Linq\Parallel\QueryOperators\QueryOpeningEnumerator.cs (2)
35private readonly ParallelMergeOptions? m_mergeOptions; 55internal QueryOpeningEnumerator(QueryOperator<TOutput> queryOperator, ParallelMergeOptions? mergeOptions, bool suppressOrderPreservation)
System\Linq\Parallel\QueryOperators\QueryOperator.cs (5)
100public IEnumerator<TOutput> GetEnumerator(ParallelMergeOptions? mergeOptions) 116internal virtual IEnumerator<TOutput> GetEnumerator(ParallelMergeOptions? mergeOptions, bool suppressOrderPreservation) 129internal IEnumerator<TOutput> GetOpenedEnumerator(ParallelMergeOptions? mergeOptions, bool suppressOrder, bool forEffect, 231new PartitionedStreamMerger<TOutput>(false, ParallelMergeOptions.FullyBuffered, querySettings.TaskScheduler, 285openedChild, false, ParallelMergeOptions.FullyBuffered, taskScheduler, outputOrdered,
System\Linq\Parallel\QueryOperators\QuerySettings.cs (8)
38private ParallelMergeOptions? m_mergeOptions; 72internal ParallelMergeOptions? MergeOptions 91ParallelMergeOptions? mergeOptions) 137ParallelMergeOptions? mergeOptions = this.MergeOptions.HasValue ? this.MergeOptions : settings2.MergeOptions; 201settings.MergeOptions = ParallelMergeOptions.Default; 204if (settings.MergeOptions == ParallelMergeOptions.Default) 206settings.MergeOptions = ParallelMergeOptions.AutoBuffered; 215Contract.Assert(settings.MergeOptions != ParallelMergeOptions.Default);
System\Linq\Parallel\QueryOperators\ScanQueryOperator.cs (1)
84internal override IEnumerator<TElement> GetEnumerator(ParallelMergeOptions? mergeOptions, bool suppressOrderPreservation)
System\Linq\Parallel\QueryOperators\Unary\AnyAllSearchOperator.cs (1)
76using (IEnumerator<bool> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Unary\ContainsSearchOperator.cs (1)
69using (IEnumerator<bool> enumerator = GetEnumerator(ParallelMergeOptions.FullyBuffered, true))
System\Linq\Parallel\QueryOperators\Unary\ElementAtQueryOperator.cs (1)
150using (IEnumerator<TSource> e = GetEnumerator(ParallelMergeOptions.FullyBuffered))
System\Linq\Parallel\QueryOperators\Unary\ForAllOperator.cs (1)
66IEnumerator<TInput> enumerator = GetOpenedEnumerator(ParallelMergeOptions.FullyBuffered, true, true,
System\Linq\ParallelEnumerable.cs (12)
430/// <seealso cref="ParallelMergeOptions"/> registered.</returns> 440public static ParallelQuery<TSource> WithMergeOptions<TSource>(this ParallelQuery<TSource> source, ParallelMergeOptions mergeOptions) 443if (mergeOptions != ParallelMergeOptions.Default 444&& mergeOptions != ParallelMergeOptions.AutoBuffered 445&& mergeOptions != ParallelMergeOptions.NotBuffered 446&& mergeOptions != ParallelMergeOptions.FullyBuffered) 4918input = asOperator.GetEnumerator(ParallelMergeOptions.FullyBuffered); 5007IEnumerator<TSource> input = (op == null) ? source.GetEnumerator() : op.GetEnumerator(ParallelMergeOptions.FullyBuffered, true); 5110IEnumerator<TSource> input = (op == null) ? source.GetEnumerator() : op.GetEnumerator(ParallelMergeOptions.FullyBuffered, true); 5202IEnumerator<IGrouping<TKey, TSource>> input = (op == null) ? groupings.GetEnumerator() : op.GetEnumerator(ParallelMergeOptions.FullyBuffered); 5289IEnumerator<IGrouping<TKey, TElement>> input = (op == null) ? groupings.GetEnumerator() : op.GetEnumerator(ParallelMergeOptions.FullyBuffered); 5383using (IEnumerator<TSource> e = queryOp.GetEnumerator(ParallelMergeOptions.FullyBuffered))