34 references to PartitionedStream
System.Core (34)
System\Linq\Parallel\Partitioning\HashRepartitionStream.cs (1)
51
:
base
(partitionsCount, orderKeyComparer, OrdinalIndexState.Shuffled)
System\Linq\Parallel\Partitioning\PartitionedDataSource.cs (1)
57
:
base
(
System\Linq\Parallel\QueryOperators\AssociativeAggregationOperator.cs (1)
203
PartitionedStream<TIntermediate, int> outputStream = new
PartitionedStream
<TIntermediate, int>(
System\Linq\Parallel\QueryOperators\Binary\ExceptQueryOperator.cs (1)
94
new
PartitionedStream
<TInputOutput, TLeftKey>(partitionCount, leftHashStream.KeyComparer, OrdinalIndexState.Shuffled);
System\Linq\Parallel\QueryOperators\Binary\GroupJoinQueryOperator.cs (1)
109
PartitionedStream<TOutput, TLeftKey> outputStream = new
PartitionedStream
<TOutput, TLeftKey>(
System\Linq\Parallel\QueryOperators\Binary\IntersectQueryOperator.cs (1)
96
new
PartitionedStream
<TInputOutput, TLeftKey>(partitionCount, leftHashStream.KeyComparer, OrdinalIndexState.Shuffled);
System\Linq\Parallel\QueryOperators\Binary\JoinQueryOperator.cs (1)
112
PartitionedStream<TOutput, TLeftKey> outputStream = new
PartitionedStream
<TOutput, TLeftKey>(
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\Inlined\InlinedAggregationOperator.cs (1)
134
PartitionedStream<TIntermediate, int> outputStream = new
PartitionedStream
<TIntermediate, int>(
System\Linq\Parallel\QueryOperators\PartitionerQueryOperator.cs (1)
147
PartitionedStream<TElement, int> partitions = new
PartitionedStream
<TElement, int>(
System\Linq\Parallel\QueryOperators\Unary\AnyAllSearchOperator.cs (1)
113
PartitionedStream<bool, int> outputStream = new
PartitionedStream
<bool, int>(
System\Linq\Parallel\QueryOperators\Unary\ConcatQueryOperator.cs (1)
127
var outputStream = new
PartitionedStream
<TSource, ConcatKey<TLeftKey, TRightKey>>(partitionCount, comparer, OrdinalIndexState);
System\Linq\Parallel\QueryOperators\Unary\ContainsSearchOperator.cs (1)
100
PartitionedStream<bool, int> outputStream = new
PartitionedStream
<bool, int>(partitionCount, Util.GetDefaultComparer<int>(), OrdinalIndexState.Correct);
System\Linq\Parallel\QueryOperators\Unary\DefaultIfEmptyQueryOperator.cs (1)
71
new
PartitionedStream
<TSource,TKey>(partitionCount, inputStream.KeyComparer, OrdinalIndexState);
System\Linq\Parallel\QueryOperators\Unary\DistinctQueryOperator.cs (1)
88
new
PartitionedStream
<TInputOutput, TKey>(partitionCount, hashStream.KeyComparer, OrdinalIndexState.Shuffled);
System\Linq\Parallel\QueryOperators\Unary\ElementAtQueryOperator.cs (1)
89
PartitionedStream<TSource, int> outputStream = new
PartitionedStream
<TSource, int>(
System\Linq\Parallel\QueryOperators\Unary\FirstQueryOperator.cs (1)
84
PartitionedStream<TSource, int> outputStream = new
PartitionedStream
<TSource, int>(
System\Linq\Parallel\QueryOperators\Unary\ForAllOperator.cs (1)
91
PartitionedStream<TInput, int> outputStream = new
PartitionedStream
<TInput, int>(
System\Linq\Parallel\QueryOperators\Unary\GroupByQueryOperator.cs (2)
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)
113
new
PartitionedStream
<TOutput, int>(partitionCount, Util.GetDefaultComparer<int>(), OrdinalIndexState);
System\Linq\Parallel\QueryOperators\Unary\IndexedWhereQueryOperator.cs (1)
107
new
PartitionedStream
<TInputOutput, int>(partitionCount, Util.GetDefaultComparer<int>(), OrdinalIndexState);
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 (1)
64
PartitionedStream<TSource, TKey> outputStream = new
PartitionedStream
<TSource, TKey>(
System\Linq\Parallel\QueryOperators\Unary\SelectManyQueryOperator.cs (2)
156
var outputStream = new
PartitionedStream
<TOutput, Pair<TLeftKey, int>>(partitionCount, keyComparer, OrdinalIndexState);
174
var outputStream = new
PartitionedStream
<TOutput, Pair<int, int>>(inputStream.PartitionCount, keyComparer, OrdinalIndexState);
System\Linq\Parallel\QueryOperators\Unary\SelectQueryOperator.cs (1)
57
new
PartitionedStream
<TOutput, TKey>(inputStream.PartitionCount, inputStream.KeyComparer, OrdinalIndexState);
System\Linq\Parallel\QueryOperators\Unary\SingleQueryOperator.cs (1)
63
PartitionedStream<TSource, int> outputStream = new
PartitionedStream
<TSource, int>(
System\Linq\Parallel\QueryOperators\Unary\SortQueryOperator.cs (1)
116
new
PartitionedStream
<TInputOutput, TSortKey>(inputStream.PartitionCount, this.m_comparer, OrdinalIndexState);
System\Linq\Parallel\QueryOperators\Unary\TakeOrSkipQueryOperator.cs (1)
116
new
PartitionedStream
<TResult, TKey>(partitionCount, inputStream.KeyComparer, OrdinalIndexState);
System\Linq\Parallel\QueryOperators\Unary\TakeOrSkipWhileQueryOperator.cs (1)
146
new
PartitionedStream
<TResult, TKey>(partitionCount, inputStream.KeyComparer, OrdinalIndexState);
System\Linq\Parallel\QueryOperators\Unary\WhereQueryOperator.cs (1)
57
PartitionedStream<TInputOutput, TKey> outputStream = new
PartitionedStream
<TInputOutput, TKey>(
System\Linq\Parallel\Utils\ExchangeUtilities.cs (1)
61
new
PartitionedStream
<T, int>(partitionCount, Util.GetDefaultComparer<int>(), OrdinalIndexState.Correct);