KeyComparer

36 references to KeyComparer

System.Linq.Parallel (36)

System\Linq\Parallel\Merging\MergeExecutor.cs (1)

70partitions, taskScheduler, cancellationState, autoBuffered, queryId, partitions.KeyComparer);

System\Linq\Parallel\Partitioning\OrderedHashRepartitionStream.cs (1)

20: base(inputStream.PartitionCount, inputStream.KeyComparer, hashKeyComparer, elementComparer)

System\Linq\Parallel\QueryOperators\Binary\ConcatQueryOperator.cs (2)

122leftStreamInc.KeyComparer, rightStreamInc.KeyComparer);

System\Linq\Parallel\QueryOperators\Binary\ExceptQueryOperator.cs (2)

90new PartitionedStream<TInputOutput, TLeftKey>(partitionCount, leftHashStream.KeyComparer, OrdinalIndexState.Shuffled); 97leftHashStream[i], rightHashStream[i], _comparer, leftHashStream.KeyComparer, cancellationToken);

System\Linq\Parallel\QueryOperators\Binary\GroupJoinQueryOperator.cs (4)

111rePartitionedRightStream[i], _keyComparer, rePartitionedRightStream.KeyComparer); 115CreateComparer(rightPartitionedStream.KeyComparer), outputRecipient, partitionCount, cancellationToken); 144IComparer<Pair<TLeftKey, TRightKey>> outputKeyComparer = new PairComparer<TLeftKey, TRightKey>(leftHashStream.KeyComparer, rightKeyComparer); 154outputKeyBuilder, leftHashStream.KeyComparer, outputRecipient, partitionCount, cancellationToken);

System\Linq\Parallel\QueryOperators\Binary\IntersectQueryOperator.cs (2)

92new PartitionedStream<TInputOutput, TLeftKey>(partitionCount, leftHashStream.KeyComparer, OrdinalIndexState.Shuffled); 98leftHashStream[i], rightHashStream[i], _comparer, leftHashStream.KeyComparer, cancellationToken);

System\Linq\Parallel\QueryOperators\Binary\JoinQueryOperator.cs (3)

119new PairComparer<TLeftKey, TRightKey>(leftHashStream.KeyComparer, rightPartitionedStream.KeyComparer); 131outputKeyBuilder, leftHashStream.KeyComparer, outputRecipient, cancellationToken);

System\Linq\Parallel\QueryOperators\Binary\UnionQueryOperator.cs (2)

126ConcatKey<TLeftKey, TRightKey>.MakeComparer(leftHashStream.KeyComparer, rightHashStream.KeyComparer);

System\Linq\Parallel\QueryOperators\Unary\DefaultIfEmptyQueryOperator.cs (1)

69new PartitionedStream<TSource, TKey>(partitionCount, inputStream.KeyComparer, OrdinalIndexState);

System\Linq\Parallel\QueryOperators\Unary\DistinctQueryOperator.cs (2)

84new PartitionedStream<TInputOutput, TKey>(partitionCount, hashStream.KeyComparer, OrdinalIndexState.Shuffled); 91new OrderedDistinctQueryOperatorEnumerator<TKey>(hashStream[i], _comparer, hashStream.KeyComparer, cancellationToken);

System\Linq\Parallel\QueryOperators\Unary\FirstQueryOperator.cs (1)

89settings.CancellationState.MergedCancellationToken, inputStream.KeyComparer, i);

System\Linq\Parallel\QueryOperators\Unary\GroupByQueryOperator.cs (3)

105new PartitionedStream<IGrouping<TGroupKey, TElement>, TKey>(partitionCount, hashStream.KeyComparer, OrdinalIndexState.Shuffled); 143new PartitionedStream<IGrouping<TGroupKey, TElement>, TKey>(partitionCount, hashStream.KeyComparer, OrdinalIndexState.Shuffled); 148IComparer<TKey> orderComparer = hashStream.KeyComparer;

System\Linq\Parallel\QueryOperators\Unary\LastQueryOperator.cs (1)

88inputStream.KeyComparer, i);

System\Linq\Parallel\QueryOperators\Unary\ReverseQueryOperator.cs (1)

60partitionCount, new ReverseComparer<TKey>(inputStream.KeyComparer), OrdinalIndexState.Shuffled);

System\Linq\Parallel\QueryOperators\Unary\SelectManyQueryOperator.cs (2)

151var keyComparer = new PairComparer<TLeftKey, int>(inputStream.KeyComparer, Util.GetDefaultComparer<int>()); 168var keyComparer = new PairComparer<int, int>(inputStream.KeyComparer, Util.GetDefaultComparer<int>());

System\Linq\Parallel\QueryOperators\Unary\SelectQueryOperator.cs (1)

53new PartitionedStream<TOutput, TKey>(inputStream.PartitionCount, inputStream.KeyComparer, OrdinalIndexState);

System\Linq\Parallel\QueryOperators\Unary\TakeOrSkipQueryOperator.cs (3)

108FixedMaxHeap<TKey> sharedIndices = new FixedMaxHeap<TKey>(_count, inputStream.KeyComparer); // an array used to track the sequence of indices leading up to the Nth index 115new PartitionedStream<TResult, TKey>(partitionCount, inputStream.KeyComparer, OrdinalIndexState); 120settings.CancellationState.MergedCancellationToken, inputStream.KeyComparer);

System\Linq\Parallel\QueryOperators\Unary\TakeOrSkipWhileQueryOperator.cs (2)

141new PartitionedStream<TResult, TKey>(partitionCount, inputStream.KeyComparer, OrdinalIndexState); 146settings.CancellationState.MergedCancellationToken, inputStream.KeyComparer);

System\Linq\Parallel\QueryOperators\Unary\WhereQueryOperator.cs (1)

54inputStream.PartitionCount, inputStream.KeyComparer, OrdinalIndexState);

System\Linq\Parallel\Utils\Sorting.cs (1)

149partitions.OrdinalIndexState, partitions.KeyComparer,