52 references to OutputOrdered
System.Linq.Parallel (52)
System\Linq\Parallel\QueryOperators\Binary\ConcatQueryOperator.cs (4)
44
_outputOrdered = LeftChild.
OutputOrdered
|| RightChild.
OutputOrdered
;
84
ExecuteAndCollectResults(leftStream, leftStream.PartitionCount, LeftChild.
OutputOrdered
, preferStriping, settings);
103
ExecuteAndCollectResults(rightStream, leftStreamInc.PartitionCount, LeftChild.
OutputOrdered
, preferStriping, settings);
System\Linq\Parallel\QueryOperators\Binary\ExceptQueryOperator.cs (3)
36
_outputOrdered = LeftChild.
OutputOrdered
;
58
if (
OutputOrdered
)
94
if (
OutputOrdered
)
System\Linq\Parallel\QueryOperators\Binary\GroupJoinQueryOperator.cs (5)
53
_outputOrdered = LeftChild.
OutputOrdered
;
78
if (LeftChild.
OutputOrdered
)
101
if (RightChild.
OutputOrdered
)
141
if (RightChild.
OutputOrdered
&& LeftChild.
OutputOrdered
)
System\Linq\Parallel\QueryOperators\Binary\IntersectQueryOperator.cs (3)
36
_outputOrdered = LeftChild.
OutputOrdered
;
60
if (
OutputOrdered
)
95
if (
OutputOrdered
)
System\Linq\Parallel\QueryOperators\Binary\JoinQueryOperator.cs (5)
69
_outputOrdered = LeftChild.
OutputOrdered
;
80
if (LeftChild.
OutputOrdered
)
85
QueryOperator<TLeftInput>.ExecuteAndCollectResults(leftStream, leftStream.PartitionCount,
OutputOrdered
, preferStriping, settings)
115
if (RightChild.
OutputOrdered
&& LeftChild.
OutputOrdered
)
System\Linq\Parallel\QueryOperators\Binary\UnionQueryOperator.cs (8)
36
_outputOrdered = LeftChild.
OutputOrdered
|| RightChild.
OutputOrdered
;
65
if (LeftChild.
OutputOrdered
)
93
if (RightChild.
OutputOrdered
)
123
if (LeftChild.
OutputOrdered
|| RightChild.
OutputOrdered
)
134
leftHashStream[i], rightHashStream[i], LeftChild.
OutputOrdered
, RightChild.
OutputOrdered
,
System\Linq\Parallel\QueryOperators\Binary\ZipQueryOperator.cs (4)
65
_outputOrdered = _leftChild.
OutputOrdered
|| _rightChild.
OutputOrdered
;
94
false, ParallelMergeOptions.FullyBuffered, settings.TaskScheduler, _leftChild.
OutputOrdered
,
105
false, ParallelMergeOptions.FullyBuffered, settings.TaskScheduler, _rightChild.
OutputOrdered
,
System\Linq\Parallel\QueryOperators\Options\QueryExecutionOption.cs (1)
25
: base(source.
OutputOrdered
, settings.Merge(source.SpecifiedQuerySettings))
System\Linq\Parallel\QueryOperators\QueryOperator.cs (3)
150
bool orderedMerge =
OutputOrdered
&& !suppressOrder;
220
if (results.IsIndexible &&
OutputOrdered
)
236
OutputOrdered
, querySettings.CancellationState, querySettings.QueryId);
System\Linq\Parallel\QueryOperators\Unary\DistinctQueryOperator.cs (2)
57
if (
OutputOrdered
)
88
if (
OutputOrdered
)
System\Linq\Parallel\QueryOperators\Unary\ElementAtQueryOperator.cs (1)
74
intKeyStream = ExecuteAndCollectResults(inputStream, partitionCount, Child.
OutputOrdered
, preferStriping, settings).GetPartitionedStream();
System\Linq\Parallel\QueryOperators\Unary\FirstQueryOperator.cs (1)
62
ListQueryResults<TSource> listResults = ExecuteAndCollectResults(inputStream, inputStream.PartitionCount, Child.
OutputOrdered
, preferStriping, settings);
System\Linq\Parallel\QueryOperators\Unary\GroupByQueryOperator.cs (1)
73
if (Child.
OutputOrdered
)
System\Linq\Parallel\QueryOperators\Unary\IndexedSelectQueryOperator.cs (1)
98
inputStream, partitionCount, Child.
OutputOrdered
, preferStriping, settings);
System\Linq\Parallel\QueryOperators\Unary\IndexedWhereQueryOperator.cs (1)
92
ListQueryResults<TInputOutput> listResults = ExecuteAndCollectResults(inputStream, partitionCount, Child.
OutputOrdered
, preferStriping, settings);
System\Linq\Parallel\QueryOperators\Unary\LastQueryOperator.cs (1)
63
ExecuteAndCollectResults(inputStream, inputStream.PartitionCount, Child.
OutputOrdered
, preferStriping, settings).GetPartitionedStream();
System\Linq\Parallel\QueryOperators\Unary\SelectManyQueryOperator.cs (4)
72
_outputOrdered = Child.
OutputOrdered
|| indexedRightChildSelector != null;
91
if (
OutputOrdered
)
116
QueryOperator<TLeftInput>.ExecuteAndCollectResults(inputStream, partitionCount,
OutputOrdered
, preferStriping, settings);
132
QueryOperator<TLeftInput>.ExecuteAndCollectResults(inputStream, partitionCount,
OutputOrdered
, preferStriping, settings)
System\Linq\Parallel\QueryOperators\Unary\TakeOrSkipQueryOperator.cs (1)
95
inputStream, inputStream.PartitionCount, Child.
OutputOrdered
, preferStriping, settings);
System\Linq\Parallel\QueryOperators\Unary\TakeOrSkipWhileQueryOperator.cs (1)
117
ListQueryResults<TResult> results = ExecuteAndCollectResults(inputStream, inputStream.PartitionCount, Child.
OutputOrdered
, preferStriping, settings);
System\Linq\Parallel\QueryOperators\UnaryQueryOperator.cs (1)
45
: this(child, child.
OutputOrdered
, child.SpecifiedQuerySettings)
System\Linq\ParallelEnumerable.cs (1)
4858
if (asOperator.OrdinalIndexState == OrdinalIndexState.Indexable && asOperator.
OutputOrdered
)