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