7 types derived from QueryOperator
System.Linq.Parallel (7)
System\Linq\Parallel\QueryOperators\Binary\ZipQueryOperator.cs (1)
28: QueryOperator<TOutput>
System\Linq\Parallel\QueryOperators\BinaryQueryOperator.cs (1)
23internal abstract class BinaryQueryOperator<TLeftInput, TRightInput, TOutput> : QueryOperator<TOutput>
System\Linq\Parallel\QueryOperators\Options\OrderingQueryOperator.cs (1)
20internal sealed class OrderingQueryOperator<TSource> : QueryOperator<TSource>
System\Linq\Parallel\QueryOperators\Options\QueryExecutionOption.cs (1)
19internal sealed class QueryExecutionOption<TSource> : QueryOperator<TSource>
System\Linq\Parallel\QueryOperators\PartitionerQueryOperator.cs (1)
25internal sealed class PartitionerQueryOperator<TElement> : QueryOperator<TElement>
System\Linq\Parallel\QueryOperators\ScanQueryOperator.cs (1)
22internal sealed class ScanQueryOperator<TElement> : QueryOperator<TElement>
System\Linq\Parallel\QueryOperators\UnaryQueryOperator.cs (1)
22internal abstract class UnaryQueryOperator<TInput, TOutput> : QueryOperator<TOutput>
67 references to QueryOperator
System.Linq.Parallel (67)
System\Linq\Parallel\Enumerables\OrderedParallelQuery.cs (3)
23private readonly QueryOperator<TSource> _sortOp; 25internal OrderedParallelQuery(QueryOperator<TSource> sortOp) 32internal QueryOperator<TSource> SortOperator
System\Linq\Parallel\Merging\ArrayMergeHelper.cs (1)
63query = new QueryExecutionOption<int>(QueryOperator<int>.AsQueryOperator(query), _settings);
System\Linq\Parallel\QueryOperators\Binary\JoinQueryOperator.cs (1)
85QueryOperator<TLeftInput>.ExecuteAndCollectResults(leftStream, leftStream.PartitionCount, OutputOrdered, preferStriping, settings)
System\Linq\Parallel\QueryOperators\Binary\ZipQueryOperator.cs (6)
31private readonly QueryOperator<TLeftInput> _leftChild; 32private readonly QueryOperator<TRightInput> _rightChild; 49QueryOperator<TLeftInput>.AsQueryOperator(leftChildSource), 50QueryOperator<TRightInput>.AsQueryOperator(rightChildSource), 56QueryOperator<TLeftInput> left, QueryOperator<TRightInput> right,
System\Linq\Parallel\QueryOperators\BinaryQueryOperator.cs (8)
26private readonly QueryOperator<TLeftInput> _leftChild; 27private readonly QueryOperator<TRightInput> _rightChild; 35: this(QueryOperator<TLeftInput>.AsQueryOperator(leftChild), QueryOperator<TRightInput>.AsQueryOperator(rightChild)) 39internal BinaryQueryOperator(QueryOperator<TLeftInput> leftChild, QueryOperator<TRightInput> rightChild) 47internal QueryOperator<TLeftInput> LeftChild 52internal QueryOperator<TRightInput> RightChild
System\Linq\Parallel\QueryOperators\Options\OrderingQueryOperator.cs (2)
22private readonly QueryOperator<TSource> _child; 25public OrderingQueryOperator(QueryOperator<TSource> child, bool orderOn)
System\Linq\Parallel\QueryOperators\Options\QueryExecutionOption.cs (2)
21private readonly QueryOperator<TSource> _child; 24internal QueryExecutionOption(QueryOperator<TSource> source, QuerySettings settings)
System\Linq\Parallel\QueryOperators\QueryOpeningEnumerator.cs (2)
25private readonly QueryOperator<TOutput> _queryOperator; 48internal QueryOpeningEnumerator(QueryOperator<TOutput> queryOperator, ParallelMergeOptions? mergeOptions, bool suppressOrderPreservation)
System\Linq\Parallel\QueryOperators\QueryOperator.cs (4)
308internal static QueryOperator<TOutput> AsQueryOperator(IEnumerable<TOutput> source) 314QueryOperator<TOutput>? sourceAsOperator = source as QueryOperator<TOutput>; 325sourceAsOperator = (QueryOperator<TOutput>)orderedQuery.SortOperator;
System\Linq\Parallel\QueryOperators\Unary\IndexedSelectQueryOperator.cs (1)
97ListQueryResults<TInput> listResults = QueryOperator<TInput>.ExecuteAndCollectResults(
System\Linq\Parallel\QueryOperators\Unary\SelectManyQueryOperator.cs (2)
116QueryOperator<TLeftInput>.ExecuteAndCollectResults(inputStream, partitionCount, OutputOrdered, preferStriping, settings); 132QueryOperator<TLeftInput>.ExecuteAndCollectResults(inputStream, partitionCount, OutputOrdered, preferStriping, settings)
System\Linq\Parallel\QueryOperators\UnaryQueryOperator.cs (7)
25private readonly QueryOperator<TInput> _child; 35: this(QueryOperator<TInput>.AsQueryOperator(child)) 40: this(QueryOperator<TInput>.AsQueryOperator(child), outputOrdered) 44private UnaryQueryOperator(QueryOperator<TInput> child) 49internal UnaryQueryOperator(QueryOperator<TInput> child, bool outputOrdered) 54private UnaryQueryOperator(QueryOperator<TInput> child, bool outputOrdered, QuerySettings settings) 60internal QueryOperator<TInput> Child
System\Linq\ParallelEnumerable.cs (28)
168return new OrderingQueryOperator<TSource>(QueryOperator<TSource>.AsQueryOperator(source), true); 199return new OrderingQueryOperator<object?>(QueryOperator<object?>.AsQueryOperator(wrapper), true); 219return new OrderingQueryOperator<TSource>(QueryOperator<TSource>.AsQueryOperator(source), false); 304QueryOperator<TSource>.AsQueryOperator(source), settings); 329QueryOperator<TSource>.AsQueryOperator(source), settings); 362QueryOperator<TSource>.AsQueryOperator(source), settings); 398QueryOperator<TSource>.AsQueryOperator(source), settings); 1183(QueryOperator<TSource>)source.OrderedEnumerable.CreateOrderedEnumerable<TKey>(keySelector, null, false)); 1214(QueryOperator<TSource>)source.OrderedEnumerable.CreateOrderedEnumerable<TKey>(keySelector, comparer, false)); 1244(QueryOperator<TSource>)source.OrderedEnumerable.CreateOrderedEnumerable<TKey>(keySelector, null, true)); 1275(QueryOperator<TSource>)source.OrderedEnumerable.CreateOrderedEnumerable<TKey>(keySelector, comparer, true)); 4379QueryOperator<TSource> leftOp = QueryOperator<TSource>.AsQueryOperator(first); 4380QueryOperator<TSource> rightOp = QueryOperator<TSource>.AsQueryOperator(second); 4820if (source is QueryOperator<TSource> asOperator) 4856if (source is QueryOperator<TSource> asOperator) 4967QueryOperator<TSource>? op = source as QueryOperator<TSource>; 5065QueryOperator<TSource>? op = source as QueryOperator<TSource>; 5150Debug.Assert(groupings is QueryOperator<IGrouping<TKey, TSource>>); 5151QueryOperator<IGrouping<TKey, TSource>>? op = groupings as QueryOperator<IGrouping<TKey, TSource>>; 5237Debug.Assert(groupings is QueryOperator<IGrouping<TKey, TElement>>); 5238QueryOperator<IGrouping<TKey, TElement>>? op = groupings as QueryOperator<IGrouping<TKey, TElement>>; 5332QueryOperator<TSource> queryOp, bool throwIfTwo, bool defaultIfEmpty)