31 references to Shuffled
System.Core (31)
System\Linq\Parallel\Partitioning\HashRepartitionStream.cs (1)
51
: base(partitionsCount, orderKeyComparer, OrdinalIndexState.
Shuffled
)
System\Linq\Parallel\QueryOperators\Binary\ExceptQueryOperator.cs (2)
41
SetOrdinalIndex(OrdinalIndexState.
Shuffled
);
94
new PartitionedStream<TInputOutput, TLeftKey>(partitionCount, leftHashStream.KeyComparer, OrdinalIndexState.
Shuffled
);
System\Linq\Parallel\QueryOperators\Binary\GroupJoinQueryOperator.cs (1)
60
SetOrdinalIndex(OrdinalIndexState.
Shuffled
);
System\Linq\Parallel\QueryOperators\Binary\IntersectQueryOperator.cs (2)
42
SetOrdinalIndex(OrdinalIndexState.
Shuffled
);
96
new PartitionedStream<TInputOutput, TLeftKey>(partitionCount, leftHashStream.KeyComparer, OrdinalIndexState.
Shuffled
);
System\Linq\Parallel\QueryOperators\Binary\JoinQueryOperator.cs (1)
76
SetOrdinalIndex(OrdinalIndexState.
Shuffled
);
System\Linq\Parallel\QueryOperators\Binary\UnionQueryOperator.cs (2)
133
new PartitionedStream<TInputOutput, ConcatKey<TLeftKey, TRightKey>>(partitionCount, compoundKeyComparer, OrdinalIndexState.
Shuffled
);
147
new PartitionedStream<TInputOutput, int>(partitionCount, Util.GetDefaultComparer<int>(), OrdinalIndexState.
Shuffled
);
System\Linq\Parallel\QueryOperators\Binary\ZipQueryOperator.cs (2)
78
(m_prematureMergeLeft && leftIndexState != OrdinalIndexState.
Shuffled
)
79
|| (m_prematureMergeRight && rightIndexState != OrdinalIndexState.
Shuffled
);
System\Linq\Parallel\QueryOperators\BinaryQueryOperator.cs (1)
32
private OrdinalIndexState m_indexState = OrdinalIndexState.
Shuffled
;
System\Linq\Parallel\QueryOperators\PartitionerQueryOperator.cs (3)
87
return OrdinalIndexState.
Shuffled
;
103
return OrdinalIndexState.
Shuffled
;
145
: OrdinalIndexState.
Shuffled
;
System\Linq\Parallel\QueryOperators\Unary\DistinctQueryOperator.cs (2)
40
SetOrdinalIndexState(OrdinalIndexState.
Shuffled
);
88
new PartitionedStream<TInputOutput, TKey>(partitionCount, hashStream.KeyComparer, OrdinalIndexState.
Shuffled
);
System\Linq\Parallel\QueryOperators\Unary\ElementAtQueryOperator.cs (1)
52
m_limitsParallelism = childIndexState != OrdinalIndexState.
Shuffled
;
System\Linq\Parallel\QueryOperators\Unary\FirstQueryOperator.cs (1)
85
partitionCount, Util.GetDefaultComparer<int>(), OrdinalIndexState.
Shuffled
);
System\Linq\Parallel\QueryOperators\Unary\GroupByQueryOperator.cs (3)
69
SetOrdinalIndexState(OrdinalIndexState.
Shuffled
);
109
new PartitionedStream<IGrouping<TGroupKey, TElement>, TKey>(partitionCount, hashStream.KeyComparer, OrdinalIndexState.
Shuffled
);
148
new PartitionedStream<IGrouping<TGroupKey, TElement>, TKey>(partitionCount, hashStream.KeyComparer, OrdinalIndexState.
Shuffled
);
System\Linq\Parallel\QueryOperators\Unary\IndexedSelectQueryOperator.cs (1)
71
m_limitsParallelism = childIndexState != OrdinalIndexState.
Shuffled
;
System\Linq\Parallel\QueryOperators\Unary\IndexedWhereQueryOperator.cs (1)
68
m_limitsParallelism = childIndexState != OrdinalIndexState.
Shuffled
;
System\Linq\Parallel\QueryOperators\Unary\LastQueryOperator.cs (1)
85
new PartitionedStream<TSource, int>(partitionCount, Util.GetDefaultComparer<int>(), OrdinalIndexState.
Shuffled
);
System\Linq\Parallel\QueryOperators\Unary\ReverseQueryOperator.cs (2)
53
SetOrdinalIndexState(OrdinalIndexState.
Shuffled
);
65
partitionCount, new ReverseComparer<TKey>(inputStream.KeyComparer), OrdinalIndexState.
Shuffled
);
System\Linq\Parallel\QueryOperators\Unary\SelectManyQueryOperator.cs (1)
91
m_limitsParallelism = m_prematureMerge && childIndexState != OrdinalIndexState.
Shuffled
;
System\Linq\Parallel\QueryOperators\Unary\SingleQueryOperator.cs (1)
64
partitionCount, Util.GetDefaultComparer<int>(), OrdinalIndexState.
Shuffled
);
System\Linq\Parallel\QueryOperators\Unary\SortQueryOperator.cs (1)
58
SetOrdinalIndexState(OrdinalIndexState.
Shuffled
);
System\Linq\Parallel\QueryOperators\UnaryQueryOperator.cs (1)
33
private OrdinalIndexState m_indexState = OrdinalIndexState.
Shuffled
;