31 references to Shuffled
System.Linq.Parallel (31)
System\Linq\Parallel\Partitioning\HashRepartitionStream.cs (1)
47
: base(partitionsCount, orderKeyComparer, OrdinalIndexState.
Shuffled
)
System\Linq\Parallel\QueryOperators\Binary\ExceptQueryOperator.cs (2)
37
SetOrdinalIndex(OrdinalIndexState.
Shuffled
);
90
new PartitionedStream<TInputOutput, TLeftKey>(partitionCount, leftHashStream.KeyComparer, OrdinalIndexState.
Shuffled
);
System\Linq\Parallel\QueryOperators\Binary\GroupJoinQueryOperator.cs (1)
55
SetOrdinalIndex(OrdinalIndexState.
Shuffled
);
System\Linq\Parallel\QueryOperators\Binary\IntersectQueryOperator.cs (2)
38
SetOrdinalIndex(OrdinalIndexState.
Shuffled
);
92
new PartitionedStream<TInputOutput, TLeftKey>(partitionCount, leftHashStream.KeyComparer, OrdinalIndexState.
Shuffled
);
System\Linq\Parallel\QueryOperators\Binary\JoinQueryOperator.cs (1)
71
SetOrdinalIndex(OrdinalIndexState.
Shuffled
);
System\Linq\Parallel\QueryOperators\Binary\UnionQueryOperator.cs (2)
129
new PartitionedStream<TInputOutput, ConcatKey<TLeftKey, TRightKey>>(partitionCount, compoundKeyComparer, OrdinalIndexState.
Shuffled
);
143
new PartitionedStream<TInputOutput, int>(partitionCount, Util.GetDefaultComparer<int>(), OrdinalIndexState.
Shuffled
);
System\Linq\Parallel\QueryOperators\Binary\ZipQueryOperator.cs (2)
73
(_prematureMergeLeft && leftIndexState != OrdinalIndexState.
Shuffled
)
74
|| (_prematureMergeRight && rightIndexState != OrdinalIndexState.
Shuffled
);
System\Linq\Parallel\QueryOperators\BinaryQueryOperator.cs (1)
28
private OrdinalIndexState _indexState = OrdinalIndexState.
Shuffled
;
System\Linq\Parallel\QueryOperators\PartitionerQueryOperator.cs (3)
81
return OrdinalIndexState.
Shuffled
;
97
return OrdinalIndexState.
Shuffled
;
139
: OrdinalIndexState.
Shuffled
;
System\Linq\Parallel\QueryOperators\Unary\DistinctQueryOperator.cs (2)
36
SetOrdinalIndexState(OrdinalIndexState.
Shuffled
);
84
new PartitionedStream<TInputOutput, TKey>(partitionCount, hashStream.KeyComparer, OrdinalIndexState.
Shuffled
);
System\Linq\Parallel\QueryOperators\Unary\ElementAtQueryOperator.cs (1)
48
_limitsParallelism = childIndexState != OrdinalIndexState.
Shuffled
;
System\Linq\Parallel\QueryOperators\Unary\FirstQueryOperator.cs (1)
83
partitionCount, Util.GetDefaultComparer<int>(), OrdinalIndexState.
Shuffled
);
System\Linq\Parallel\QueryOperators\Unary\GroupByQueryOperator.cs (3)
65
SetOrdinalIndexState(OrdinalIndexState.
Shuffled
);
105
new PartitionedStream<IGrouping<TGroupKey, TElement>, TKey>(partitionCount, hashStream.KeyComparer, OrdinalIndexState.
Shuffled
);
143
new PartitionedStream<IGrouping<TGroupKey, TElement>, TKey>(partitionCount, hashStream.KeyComparer, OrdinalIndexState.
Shuffled
);
System\Linq\Parallel\QueryOperators\Unary\IndexedSelectQueryOperator.cs (1)
67
_limitsParallelism = childIndexState != OrdinalIndexState.
Shuffled
;
System\Linq\Parallel\QueryOperators\Unary\IndexedWhereQueryOperator.cs (1)
64
_limitsParallelism = childIndexState != OrdinalIndexState.
Shuffled
;
System\Linq\Parallel\QueryOperators\Unary\LastQueryOperator.cs (1)
83
new PartitionedStream<TSource, int>(partitionCount, Util.GetDefaultComparer<int>(), OrdinalIndexState.
Shuffled
);
System\Linq\Parallel\QueryOperators\Unary\ReverseQueryOperator.cs (2)
49
SetOrdinalIndexState(OrdinalIndexState.
Shuffled
);
60
partitionCount, new ReverseComparer<TKey>(inputStream.KeyComparer), OrdinalIndexState.
Shuffled
);
System\Linq\Parallel\QueryOperators\Unary\SelectManyQueryOperator.cs (1)
87
_limitsParallelism = _prematureMerge && childIndexState != OrdinalIndexState.
Shuffled
;
System\Linq\Parallel\QueryOperators\Unary\SingleQueryOperator.cs (1)
60
partitionCount, Util.GetDefaultComparer<int>(), OrdinalIndexState.
Shuffled
);
System\Linq\Parallel\QueryOperators\Unary\SortQueryOperator.cs (1)
47
SetOrdinalIndexState(OrdinalIndexState.
Shuffled
);
System\Linq\Parallel\QueryOperators\UnaryQueryOperator.cs (1)
28
private OrdinalIndexState _indexState = OrdinalIndexState.
Shuffled
;