31 references to KeyComparer
System.Core (31)
System\Linq\Parallel\Merging\MergeExecutor.cs (1)
74
partitions, taskScheduler, cancellationState, autoBuffered, queryId, partitions.
KeyComparer
);
System\Linq\Parallel\Partitioning\OrderedHashRepartitionStream.cs (1)
24
: base(inputStream.PartitionCount, inputStream.
KeyComparer
, hashKeyComparer, elementComparer)
System\Linq\Parallel\QueryOperators\Binary\ExceptQueryOperator.cs (2)
94
new PartitionedStream<TInputOutput, TLeftKey>(partitionCount, leftHashStream.
KeyComparer
, OrdinalIndexState.Shuffled);
101
leftHashStream[i], rightHashStream[i], m_comparer, leftHashStream.
KeyComparer
, cancellationToken);
System\Linq\Parallel\QueryOperators\Binary\GroupJoinQueryOperator.cs (1)
110
partitionCount, leftHashStream.
KeyComparer
, OrdinalIndexState);
System\Linq\Parallel\QueryOperators\Binary\IntersectQueryOperator.cs (2)
96
new PartitionedStream<TInputOutput, TLeftKey>(partitionCount, leftHashStream.
KeyComparer
, OrdinalIndexState.Shuffled);
102
leftHashStream[i], rightHashStream[i], m_comparer, leftHashStream.
KeyComparer
, cancellationToken);
System\Linq\Parallel\QueryOperators\Binary\JoinQueryOperator.cs (1)
113
partitionCount, leftHashStream.
KeyComparer
, OrdinalIndexState);
System\Linq\Parallel\QueryOperators\Binary\UnionQueryOperator.cs (2)
130
ConcatKey<TLeftKey, TRightKey>.MakeComparer(leftHashStream.
KeyComparer
, rightHashStream.
KeyComparer
);
System\Linq\Parallel\QueryOperators\Unary\ConcatQueryOperator.cs (2)
126
leftStreamInc.
KeyComparer
, rightStreamInc.
KeyComparer
);
System\Linq\Parallel\QueryOperators\Unary\DefaultIfEmptyQueryOperator.cs (1)
71
new PartitionedStream<TSource,TKey>(partitionCount, inputStream.
KeyComparer
, OrdinalIndexState);
System\Linq\Parallel\QueryOperators\Unary\DistinctQueryOperator.cs (2)
88
new PartitionedStream<TInputOutput, TKey>(partitionCount, hashStream.
KeyComparer
, OrdinalIndexState.Shuffled);
95
new OrderedDistinctQueryOperatorEnumerator<TKey>(hashStream[i], m_comparer, hashStream.
KeyComparer
, cancellationToken);
System\Linq\Parallel\QueryOperators\Unary\FirstQueryOperator.cs (1)
91
settings.CancellationState.MergedCancellationToken, inputStream.
KeyComparer
, i);
System\Linq\Parallel\QueryOperators\Unary\GroupByQueryOperator.cs (3)
109
new PartitionedStream<IGrouping<TGroupKey, TElement>, TKey>(partitionCount, hashStream.
KeyComparer
, OrdinalIndexState.Shuffled);
148
new PartitionedStream<IGrouping<TGroupKey, TElement>, TKey>(partitionCount, hashStream.
KeyComparer
, OrdinalIndexState.Shuffled);
153
IComparer<TKey> orderComparer = hashStream.
KeyComparer
;
System\Linq\Parallel\QueryOperators\Unary\LastQueryOperator.cs (1)
90
inputStream.
KeyComparer
, i);
System\Linq\Parallel\QueryOperators\Unary\ReverseQueryOperator.cs (1)
65
partitionCount, new ReverseComparer<TKey>(inputStream.
KeyComparer
), OrdinalIndexState.Shuffled);
System\Linq\Parallel\QueryOperators\Unary\SelectManyQueryOperator.cs (2)
155
var keyComparer = new PairComparer<TLeftKey, int>(inputStream.
KeyComparer
, Util.GetDefaultComparer<int>());
172
var keyComparer = new PairComparer<int, int>(inputStream.
KeyComparer
, Util.GetDefaultComparer<int>());
System\Linq\Parallel\QueryOperators\Unary\SelectQueryOperator.cs (1)
57
new PartitionedStream<TOutput, TKey>(inputStream.PartitionCount, inputStream.
KeyComparer
, OrdinalIndexState);
System\Linq\Parallel\QueryOperators\Unary\TakeOrSkipQueryOperator.cs (3)
112
FixedMaxHeap<TKey> sharedIndices = new FixedMaxHeap<TKey>(m_count, inputStream.
KeyComparer
); // an array used to track the sequence of indices leading up to the Nth index
116
new PartitionedStream<TResult, TKey>(partitionCount, inputStream.
KeyComparer
, OrdinalIndexState);
121
settings.CancellationState.MergedCancellationToken, inputStream.
KeyComparer
);
System\Linq\Parallel\QueryOperators\Unary\TakeOrSkipWhileQueryOperator.cs (2)
146
new PartitionedStream<TResult, TKey>(partitionCount, inputStream.
KeyComparer
, OrdinalIndexState);
151
settings.CancellationState.MergedCancellationToken, inputStream.
KeyComparer
);
System\Linq\Parallel\QueryOperators\Unary\WhereQueryOperator.cs (1)
58
inputStream.PartitionCount, inputStream.
KeyComparer
, OrdinalIndexState);
System\Linq\Parallel\Utils\Sorting.cs (1)
151
partitions.OrdinalIndexState, partitions.
KeyComparer
,