34 references to PartitionedStream
System.Linq.Parallel (34)
System\Linq\Parallel\Partitioning\HashRepartitionStream.cs (1)
47
:
base
(partitionsCount, orderKeyComparer, OrdinalIndexState.Shuffled)
System\Linq\Parallel\Partitioning\PartitionedDataSource.cs (1)
53
:
base
(
System\Linq\Parallel\QueryOperators\AssociativeAggregationOperator.cs (1)
186
PartitionedStream<TIntermediate, int> outputStream = new
PartitionedStream
<TIntermediate, int>(
System\Linq\Parallel\QueryOperators\Binary\ConcatQueryOperator.cs (1)
123
var outputStream = new
PartitionedStream
<TSource, ConcatKey<TLeftKey, TRightKey>>(partitionCount, comparer, OrdinalIndexState);
System\Linq\Parallel\QueryOperators\Binary\ExceptQueryOperator.cs (1)
90
new
PartitionedStream
<TInputOutput, TLeftKey>(partitionCount, leftHashStream.KeyComparer, OrdinalIndexState.Shuffled);
System\Linq\Parallel\QueryOperators\Binary\GroupJoinQueryOperator.cs (1)
174
PartitionedStream<TOutput, TOutputKey> outputStream = new
PartitionedStream
<TOutput, TOutputKey>(
System\Linq\Parallel\QueryOperators\Binary\IntersectQueryOperator.cs (1)
92
new
PartitionedStream
<TInputOutput, TLeftKey>(partitionCount, leftHashStream.KeyComparer, OrdinalIndexState.Shuffled);
System\Linq\Parallel\QueryOperators\Binary\JoinQueryOperator.cs (1)
143
new
PartitionedStream
<TOutput, TOutputKey>(partitionCount, outputKeyComparer, OrdinalIndexState);
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\Inlined\InlinedAggregationOperator.cs (1)
124
PartitionedStream<TIntermediate, int> outputStream = new
PartitionedStream
<TIntermediate, int>(
System\Linq\Parallel\QueryOperators\PartitionerQueryOperator.cs (1)
141
PartitionedStream<TElement, int> partitions = new
PartitionedStream
<TElement, int>(
System\Linq\Parallel\QueryOperators\Unary\AnyAllSearchOperator.cs (1)
109
PartitionedStream<bool, int> outputStream = new
PartitionedStream
<bool, int>(
System\Linq\Parallel\QueryOperators\Unary\ContainsSearchOperator.cs (1)
87
PartitionedStream<bool, int> outputStream = new
PartitionedStream
<bool, int>(partitionCount, Util.GetDefaultComparer<int>(), OrdinalIndexState.Correct);
System\Linq\Parallel\QueryOperators\Unary\DefaultIfEmptyQueryOperator.cs (1)
69
new
PartitionedStream
<TSource, TKey>(partitionCount, inputStream.KeyComparer, OrdinalIndexState);
System\Linq\Parallel\QueryOperators\Unary\DistinctQueryOperator.cs (1)
84
new
PartitionedStream
<TInputOutput, TKey>(partitionCount, hashStream.KeyComparer, OrdinalIndexState.Shuffled);
System\Linq\Parallel\QueryOperators\Unary\ElementAtQueryOperator.cs (1)
85
PartitionedStream<TSource, int> outputStream = new
PartitionedStream
<TSource, int>(
System\Linq\Parallel\QueryOperators\Unary\FirstQueryOperator.cs (1)
82
PartitionedStream<TSource, int> outputStream = new
PartitionedStream
<TSource, int>(
System\Linq\Parallel\QueryOperators\Unary\ForAllOperator.cs (1)
87
PartitionedStream<TInput, int> outputStream = new
PartitionedStream
<TInput, int>(
System\Linq\Parallel\QueryOperators\Unary\GroupByQueryOperator.cs (2)
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)
109
new
PartitionedStream
<TOutput, int>(partitionCount, Util.GetDefaultComparer<int>(), OrdinalIndexState);
System\Linq\Parallel\QueryOperators\Unary\IndexedWhereQueryOperator.cs (1)
103
new
PartitionedStream
<TInputOutput, int>(partitionCount, Util.GetDefaultComparer<int>(), OrdinalIndexState);
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 (1)
59
PartitionedStream<TSource, TKey> outputStream = new
PartitionedStream
<TSource, TKey>(
System\Linq\Parallel\QueryOperators\Unary\SelectManyQueryOperator.cs (2)
152
var outputStream = new
PartitionedStream
<TOutput, Pair<TLeftKey, int>>(partitionCount, keyComparer, OrdinalIndexState);
170
var outputStream = new
PartitionedStream
<TOutput, Pair<int, int>>(inputStream.PartitionCount, keyComparer, OrdinalIndexState);
System\Linq\Parallel\QueryOperators\Unary\SelectQueryOperator.cs (1)
53
new
PartitionedStream
<TOutput, TKey>(inputStream.PartitionCount, inputStream.KeyComparer, OrdinalIndexState);
System\Linq\Parallel\QueryOperators\Unary\SingleQueryOperator.cs (1)
59
PartitionedStream<TSource, int> outputStream = new
PartitionedStream
<TSource, int>(
System\Linq\Parallel\QueryOperators\Unary\SortQueryOperator.cs (1)
87
new
PartitionedStream
<TInputOutput, TSortKey>(inputStream.PartitionCount, this._comparer, OrdinalIndexState);
System\Linq\Parallel\QueryOperators\Unary\TakeOrSkipQueryOperator.cs (1)
115
new
PartitionedStream
<TResult, TKey>(partitionCount, inputStream.KeyComparer, OrdinalIndexState);
System\Linq\Parallel\QueryOperators\Unary\TakeOrSkipWhileQueryOperator.cs (1)
141
new
PartitionedStream
<TResult, TKey>(partitionCount, inputStream.KeyComparer, OrdinalIndexState);
System\Linq\Parallel\QueryOperators\Unary\WhereQueryOperator.cs (1)
53
PartitionedStream<TInputOutput, TKey> outputStream = new
PartitionedStream
<TInputOutput, TKey>(
System\Linq\Parallel\Utils\ExchangeUtilities.cs (1)
53
new
PartitionedStream
<T, int>(partitionCount, Util.GetDefaultComparer<int>(), OrdinalIndexState.Correct);