7 types derived from QueryOperator
System.Core (7)
System\Linq\Parallel\QueryOperators\Binary\ZipQueryOperator.cs (1)
32
:
QueryOperator
<TOutput>
System\Linq\Parallel\QueryOperators\BinaryQueryOperator.cs (1)
27
internal abstract class BinaryQueryOperator<TLeftInput, TRightInput, TOutput> :
QueryOperator
<TOutput>
System\Linq\Parallel\QueryOperators\Options\OrderingQueryOperator.cs (1)
24
internal sealed class OrderingQueryOperator<TSource> :
QueryOperator
<TSource>
System\Linq\Parallel\QueryOperators\Options\QueryExecutionOption.cs (1)
22
internal class QueryExecutionOption<TSource> :
QueryOperator
<TSource>
System\Linq\Parallel\QueryOperators\PartitionerQueryOperator.cs (1)
31
internal class PartitionerQueryOperator<TElement> :
QueryOperator
<TElement>
System\Linq\Parallel\QueryOperators\ScanQueryOperator.cs (1)
26
internal sealed class ScanQueryOperator<TElement> :
QueryOperator
<TElement>
System\Linq\Parallel\QueryOperators\UnaryQueryOperator.cs (1)
26
internal abstract class UnaryQueryOperator<TInput, TOutput> :
QueryOperator
<TOutput>
69 references to QueryOperator
System.Core (69)
System\Linq\Parallel\Enumerables\OrderedParallelQuery.cs (3)
27
private
QueryOperator
<TSource> m_sortOp;
29
internal OrderedParallelQuery(
QueryOperator
<TSource> sortOp)
36
internal
QueryOperator
<TSource> SortOperator
System\Linq\Parallel\Merging\ArrayMergeHelper.cs (1)
67
query = new QueryExecutionOption<int>(
QueryOperator
<int>.AsQueryOperator(query), m_settings);
System\Linq\Parallel\QueryOperators\Binary\ZipQueryOperator.cs (6)
36
private readonly
QueryOperator
<TLeftInput> m_leftChild;
37
private readonly
QueryOperator
<TRightInput> m_rightChild;
54
QueryOperator
<TLeftInput>.AsQueryOperator(leftChildSource),
55
QueryOperator
<TRightInput>.AsQueryOperator(rightChildSource),
61
QueryOperator
<TLeftInput> left,
QueryOperator
<TRightInput> right,
System\Linq\Parallel\QueryOperators\BinaryQueryOperator.cs (8)
30
private readonly
QueryOperator
<TLeftInput> m_leftChild;
31
private readonly
QueryOperator
<TRightInput> m_rightChild;
39
:this(
QueryOperator
<TLeftInput>.AsQueryOperator(leftChild),
QueryOperator
<TRightInput>.AsQueryOperator(rightChild))
43
internal BinaryQueryOperator(
QueryOperator
<TLeftInput> leftChild,
QueryOperator
<TRightInput> rightChild)
51
internal
QueryOperator
<TLeftInput> LeftChild
56
internal
QueryOperator
<TRightInput> RightChild
System\Linq\Parallel\QueryOperators\Options\OrderingQueryOperator.cs (2)
28
private
QueryOperator
<TSource> m_child;
31
public OrderingQueryOperator(
QueryOperator
<TSource> child, bool orderOn)
System\Linq\Parallel\QueryOperators\Options\QueryExecutionOption.cs (2)
24
private
QueryOperator
<TSource> m_child;
27
internal QueryExecutionOption(
QueryOperator
<TSource> source, QuerySettings settings)
System\Linq\Parallel\QueryOperators\QueryOpeningEnumerator.cs (2)
32
private readonly
QueryOperator
<TOutput> m_queryOperator;
55
internal QueryOpeningEnumerator(
QueryOperator
<TOutput> queryOperator, ParallelMergeOptions? mergeOptions, bool suppressOrderPreservation)
System\Linq\Parallel\QueryOperators\QueryOperator.cs (4)
303
internal static
QueryOperator
<TOutput> AsQueryOperator(IEnumerable<TOutput> source)
309
QueryOperator
<TOutput> sourceAsOperator = source as
QueryOperator
<TOutput>;
321
sourceAsOperator = (
QueryOperator
<TOutput>)orderedQuery.SortOperator;
System\Linq\Parallel\QueryOperators\Unary\IndexedSelectQueryOperator.cs (1)
101
ListQueryResults<TInput> listResults =
QueryOperator
<TInput>.ExecuteAndCollectResults(
System\Linq\Parallel\QueryOperators\Unary\SelectManyQueryOperator.cs (2)
120
QueryOperator
<TLeftInput>.ExecuteAndCollectResults(inputStream, partitionCount, OutputOrdered, preferStriping, settings);
136
QueryOperator
<TLeftInput>.ExecuteAndCollectResults(inputStream, partitionCount, OutputOrdered, preferStriping, settings)
System\Linq\Parallel\QueryOperators\UnaryQueryOperator.cs (7)
30
private readonly
QueryOperator
<TInput> m_child;
40
: this(
QueryOperator
<TInput>.AsQueryOperator(child))
45
: this(
QueryOperator
<TInput>.AsQueryOperator(child), outputOrdered)
49
private UnaryQueryOperator(
QueryOperator
<TInput> child)
54
internal UnaryQueryOperator(
QueryOperator
<TInput> child, bool outputOrdered)
59
private UnaryQueryOperator(
QueryOperator
<TInput> child, bool outputOrdered, QuerySettings settings)
65
internal
QueryOperator
<TInput> Child
System\Linq\ParallelEnumerable.cs (31)
174
return new OrderingQueryOperator<TSource>(
QueryOperator
<TSource>.AsQueryOperator(source), true);
208
return new OrderingQueryOperator<object>(
QueryOperator
<object>.AsQueryOperator(wrapper), true);
231
return new OrderingQueryOperator<TSource>(
QueryOperator
<TSource>.AsQueryOperator(source), false);
312
QueryOperator
<TSource>.AsQueryOperator(source), settings);
344
QueryOperator
<TSource>.AsQueryOperator(source), settings);
388
QueryOperator
<TSource>.AsQueryOperator(source), settings);
420
QueryOperator
<TSource>.AsQueryOperator(source), settings);
455
QueryOperator
<TSource>.AsQueryOperator(source), settings);
1239
(
QueryOperator
<TSource>)source.OrderedEnumerable.CreateOrderedEnumerable<TKey>(keySelector, null, false));
1269
(
QueryOperator
<TSource>)source.OrderedEnumerable.CreateOrderedEnumerable<TKey>(keySelector, comparer, false));
1298
(
QueryOperator
<TSource>)source.OrderedEnumerable.CreateOrderedEnumerable<TKey>(keySelector, null, true));
1328
(
QueryOperator
<TSource>)source.OrderedEnumerable.CreateOrderedEnumerable<TKey>(keySelector, comparer, true));
4405
QueryOperator
<TSource> leftOp =
QueryOperator
<TSource>.AsQueryOperator(first);
4406
QueryOperator
<TSource> rightOp =
QueryOperator
<TSource>.AsQueryOperator(second);
4856
QueryOperator
<TSource> asOperator = source as
QueryOperator
<TSource>;
4893
QueryOperator
<TSource> asOperator = source as
QueryOperator
<TSource>;
5006
QueryOperator
<TSource> op = source as
QueryOperator
<TSource>;
5109
QueryOperator
<TSource> op = source as
QueryOperator
<TSource>;
5199
Contract.Assert(groupings is
QueryOperator
<IGrouping<TKey, TSource>>);
5200
QueryOperator
<IGrouping<TKey, TSource>> op = groupings as
QueryOperator
<IGrouping<TKey, TSource>>;
5286
Contract.Assert(groupings is
QueryOperator
<IGrouping<TKey, TElement>>);
5287
QueryOperator
<IGrouping<TKey, TElement>> op = groupings as
QueryOperator
<IGrouping<TKey, TElement>>;
5379
QueryOperator
<TSource> queryOp, bool throwIfTwo, bool defaultIfEmpty)