PartitionedStream

System\Linq\Parallel\Merging\DefaultMergeHelper.cs (2)

29private readonly PartitionedStream<TInputOutput, TIgnoreKey> _partitions; // Source partitions. 45internal DefaultMergeHelper(PartitionedStream<TInputOutput, TIgnoreKey> partitions, bool ignoreOutput, ParallelMergeOptions options,

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

50PartitionedStream<TInputOutput, TKey> partitions, bool ignoreOutput, ParallelMergeOptions options, TaskScheduler taskScheduler, bool isOrdered,

System\Linq\Parallel\Merging\OrderPreservingMergeHelper.cs (2)

26private readonly PartitionedStream<TInputOutput, TKey> _partitions; // Source partitions. 38internal OrderPreservingMergeHelper(PartitionedStream<TInputOutput, TKey> partitions, TaskScheduler taskScheduler,

System\Linq\Parallel\Merging\OrderPreservingPipeliningMergeHelper.cs (2)

45private readonly PartitionedStream<TOutput, TKey> _partitions; // Source partitions. 115PartitionedStream<TOutput, TKey> partitions,

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

19void Receive<TKey>(PartitionedStream<TElement, TKey> partitionedStream);

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

18PartitionedStream<TInputOutput, TOrderKey> inputStream, Func<TInputOutput, THashKey>? hashKeySelector,

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

22PartitionedStream<TInputOutput, TIgnoreKey> inputStream,

System\Linq\Parallel\QueryOperators\AssociativeAggregationOperator.cs (2)

182PartitionedStream<TInput, TKey> inputStream, IPartitionedStreamRecipient<TIntermediate> recipient, 186PartitionedStream<TIntermediate, int> outputStream = new PartitionedStream<TIntermediate, int>(

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

77PartitionedStream<TSource, TLeftKey> leftStream, PartitionedStream<TSource, TRightKey> rightStream, 85PartitionedStream<TSource, int> leftStreamInc = leftStreamResults.GetPartitionedStream(); 96PartitionedStream<TSource, TLeftKey> leftStreamInc, PartitionedStream<TSource, TRightKey> rightStream, 104PartitionedStream<TSource, int> rightStreamInc = rightStreamResults.GetPartitionedStream(); 115PartitionedStream<TSource, TLeftKey> leftStreamInc, PartitionedStream<TSource, TRightKey> rightStreamInc, 123var outputStream = new PartitionedStream<TSource, ConcatKey<TLeftKey, TRightKey>>(partitionCount, comparer, OrdinalIndexState);

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

53PartitionedStream<TInputOutput, TLeftKey> leftStream, PartitionedStream<TInputOutput, TRightKey> rightStream, 80PartitionedStream<Pair<TInputOutput, NoKeyMemoizationRequired>, TLeftKey> leftHashStream, PartitionedStream<TInputOutput, TRightKey> rightPartitionedStream, 85PartitionedStream<Pair<TInputOutput, NoKeyMemoizationRequired>, int> rightHashStream = 89PartitionedStream<TInputOutput, TLeftKey> outputStream =

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

72PartitionedStream<TLeftInput, TLeftKey> leftStream, PartitionedStream<TRightInput, TRightKey> rightStream, 98PartitionedStream<Pair<TLeftInput, TKey>, TLeftKey> leftHashStream, PartitionedStream<TRightInput, TRightKey> rightPartitionedStream, 103PartitionedStream<Pair<TRightInput, TKey>, TRightKey> rePartitionedRightStream = ExchangeUtilities.HashRepartitionOrdered( 119PartitionedStream<Pair<TRightInput, TKey>, int> rePartitionedRightStream = ExchangeUtilities.HashRepartition( 136PartitionedStream<Pair<TLeftInput, TKey>, TLeftKey> leftHashStream, 169PartitionedStream<Pair<TLeftInput, TKey>, TLeftKey> leftHashStream, 174PartitionedStream<TOutput, TOutputKey> outputStream = new PartitionedStream<TOutput, TOutputKey>(

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

55PartitionedStream<TInputOutput, TLeftKey> leftPartitionedStream, PartitionedStream<TInputOutput, TRightKey> rightPartitionedStream, 82PartitionedStream<Pair<TInputOutput, NoKeyMemoizationRequired>, TLeftKey> leftHashStream, PartitionedStream<TInputOutput, TRightKey> rightPartitionedStream, 87PartitionedStream<Pair<TInputOutput, NoKeyMemoizationRequired>, int> rightHashStream = 91PartitionedStream<TInputOutput, TLeftKey> outputStream =

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

75PartitionedStream<TLeftInput, TLeftKey> leftStream, PartitionedStream<TRightInput, TRightKey> rightStream, 84PartitionedStream<TLeftInput, int> leftStreamInt = 112PartitionedStream<Pair<TLeftInput, TKey>, TLeftKey> leftHashStream, PartitionedStream<TRightInput, TRightKey> rightPartitionedStream, 136PartitionedStream<Pair<TLeftInput, TKey>, TLeftKey> leftHashStream, PartitionedStream<Pair<TRightInput, TKey>, TRightKey> rightHashStream, 142PartitionedStream<TOutput, TOutputKey> outputStream =

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

57PartitionedStream<TInputOutput, TLeftKey> leftStream, PartitionedStream<TInputOutput, TRightKey> rightStream, 67PartitionedStream<Pair<TInputOutput, NoKeyMemoizationRequired>, TLeftKey> leftHashStream = 76PartitionedStream<Pair<TInputOutput, NoKeyMemoizationRequired>, int> leftHashStream = 90PartitionedStream<Pair<TInputOutput, NoKeyMemoizationRequired>, TLeftKey> leftHashStream, PartitionedStream<TInputOutput, TRightKey> rightStream, 95PartitionedStream<Pair<TInputOutput, NoKeyMemoizationRequired>, TRightKey> rightHashStream = 104PartitionedStream<Pair<TInputOutput, NoKeyMemoizationRequired>, int> rightHashStream = 118PartitionedStream<Pair<TInputOutput, NoKeyMemoizationRequired>, TLeftKey> leftHashStream, 119PartitionedStream<Pair<TInputOutput, NoKeyMemoizationRequired>, TRightKey> rightHashStream, 128PartitionedStream<TInputOutput, ConcatKey<TLeftKey, TRightKey>> outputStream = 142PartitionedStream<TInputOutput, int> outputStream =

System\Linq\Parallel\QueryOperators\Binary\ZipQueryOperator.cs (1)

204PartitionedStream<TOutput, int> partitionedStream = ExchangeUtilities.PartitionDataSource(this, _partitionCount, _preferStriping);

System\Linq\Parallel\QueryOperators\BinaryQueryOperator.cs (8)

75PartitionedStream<TLeftInput, TLeftKey> leftPartitionedStream, PartitionedStream<TRightInput, TRightKey> rightPartitionedStream, 113PartitionedStream<TOutput, int> result = ExchangeUtilities.PartitionDataSource( 121PartitionedStream<TOutput, int> result = ExchangeUtilities.PartitionDataSource(this, _settings.DegreeOfParallelism.Value, _preferStriping); 153public void Receive<TLeftKey>(PartitionedStream<TLeftInput, TLeftKey> source) 173private readonly PartitionedStream<TLeftInput, TLeftKey> _leftPartitionedStream; 180PartitionedStream<TLeftInput, TLeftKey> leftPartitionedStream, bool preferStriping, QuerySettings settings) 189public void Receive<TRightKey>(PartitionedStream<TRightInput, TRightKey> rightPartitionedStream)

System\Linq\Parallel\QueryOperators\Inlined\InlinedAggregationOperator.cs (2)

120PartitionedStream<TSource, TKey> inputStream, IPartitionedStreamRecipient<TIntermediate> recipient, 124PartitionedStream<TIntermediate, int> outputStream = new PartitionedStream<TIntermediate, int>(

System\Linq\Parallel\QueryOperators\ListQueryResults.cs (2)

33PartitionedStream<T, int> partitionedStream = GetPartitionedStream(); 52internal PartitionedStream<T, int> GetPartitionedStream()

System\Linq\Parallel\QueryOperators\PartitionedStreamMerger.cs (1)

55public void Receive<TKey>(PartitionedStream<TOutput, TKey> partitionedStream)

System\Linq\Parallel\QueryOperators\PartitionerQueryOperator.cs (1)

141PartitionedStream<TElement, int> partitions = new PartitionedStream<TElement, int>(

System\Linq\Parallel\QueryOperators\QueryOperator.cs (1)

280PartitionedStream<TOutput, TKey> openedChild,

System\Linq\Parallel\QueryOperators\ScanQueryOperator.cs (1)

133PartitionedStream<TElement, int> partitionedStream = ExchangeUtilities.PartitionDataSource(

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

103PartitionedStream<TInput, TKey> inputStream, IPartitionedStreamRecipient<bool> recipient, bool preferStriping, QuerySettings settings) 109PartitionedStream<bool, int> outputStream = new PartitionedStream<bool, int>(

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

84PartitionedStream<TInput, TKey> inputStream, IPartitionedStreamRecipient<bool> recipient, bool preferStriping, QuerySettings settings) 87PartitionedStream<bool, int> outputStream = new PartitionedStream<bool, int>(partitionCount, Util.GetDefaultComparer<int>(), OrdinalIndexState.Correct);

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

58PartitionedStream<TSource, TKey> inputStream, IPartitionedStreamRecipient<TSource> recipient, bool preferStriping, QuerySettings settings) 68PartitionedStream<TSource, TKey> outputStream =

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

54PartitionedStream<TInputOutput, TKey> inputStream, IPartitionedStreamRecipient<TInputOutput> recipient, bool preferStriping, QuerySettings settings) 79PartitionedStream<Pair<TInputOutput, NoKeyMemoizationRequired>, TKey> hashStream, 83PartitionedStream<TInputOutput, TKey> outputStream =

System\Linq\Parallel\QueryOperators\Unary\ElementAtQueryOperator.cs (4)

66PartitionedStream<TSource, TKey> inputStream, IPartitionedStreamRecipient<TSource> recipient, bool preferStriping, QuerySettings settings) 71PartitionedStream<TSource, int> intKeyStream; 79intKeyStream = (PartitionedStream<TSource, int>)(object)inputStream; 85PartitionedStream<TSource, int> outputStream = new PartitionedStream<TSource, int>(

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

57PartitionedStream<TSource, TKey> inputStream, IPartitionedStreamRecipient<TSource> recipient, bool preferStriping, QuerySettings settings) 72PartitionedStream<TSource, TKey> inputStream, IPartitionedStreamRecipient<TSource> recipient, QuerySettings settings) 82PartitionedStream<TSource, int> outputStream = new PartitionedStream<TSource, int>(

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

84PartitionedStream<TInput, TKey> inputStream, IPartitionedStreamRecipient<TInput> recipient, bool preferStriping, QuerySettings settings) 87PartitionedStream<TInput, int> outputStream = new PartitionedStream<TInput, int>(

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

69PartitionedStream<TSource, TKey> inputStream, IPartitionedStreamRecipient<IGrouping<TGroupKey, TElement>> recipient, 99PartitionedStream<Pair<TSource, TGroupKey>, TKey> hashStream, 104PartitionedStream<IGrouping<TGroupKey, TElement>, TKey> outputStream = 137PartitionedStream<Pair<TSource, TGroupKey>, TKey> hashStream, 142PartitionedStream<IGrouping<TGroupKey, TElement>, TKey> outputStream =

System\Linq\Parallel\QueryOperators\Unary\IndexedSelectQueryOperator.cs (4)

89PartitionedStream<TInput, TKey> inputStream, IPartitionedStreamRecipient<TOutput> recipient, bool preferStriping, QuerySettings settings) 94PartitionedStream<TInput, int> inputStreamInt; 104inputStreamInt = (PartitionedStream<TInput, int>)(object)inputStream; 108PartitionedStream<TOutput, int> outputStream =

System\Linq\Parallel\QueryOperators\Unary\IndexedWhereQueryOperator.cs (4)

84PartitionedStream<TInputOutput, TKey> inputStream, IPartitionedStreamRecipient<TInputOutput> recipient, bool preferStriping, QuerySettings settings) 89PartitionedStream<TInputOutput, int> inputStreamInt; 98inputStreamInt = (PartitionedStream<TInputOutput, int>)(object)inputStream; 102PartitionedStream<TInputOutput, int> outputStream =

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

57PartitionedStream<TSource, TKey> inputStream, IPartitionedStreamRecipient<TSource> recipient, bool preferStriping, QuerySettings settings) 62PartitionedStream<TSource, int> intKeyStream = 72private void WrapHelper<TKey>(PartitionedStream<TSource, TKey> inputStream, IPartitionedStreamRecipient<TSource> recipient, QuerySettings settings) 82PartitionedStream<TSource, int> outputStream =

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

54PartitionedStream<TSource, TKey> inputStream, IPartitionedStreamRecipient<TSource> recipient, bool preferStriping, QuerySettings settings) 59PartitionedStream<TSource, TKey> outputStream = new PartitionedStream<TSource, TKey>(

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

104PartitionedStream<TLeftInput, TLeftKey> inputStream, IPartitionedStreamRecipient<TOutput> recipient, bool preferStriping, QuerySettings settings) 110PartitionedStream<TLeftInput, int> inputStreamInt; 121inputStreamInt = (PartitionedStream<TLeftInput, int>)(object)inputStream; 131PartitionedStream<TLeftInput, int> inputStreamInt = 148PartitionedStream<TLeftInput, TLeftKey> inputStream, IPartitionedStreamRecipient<TOutput> recipient, QuerySettings settings) 152var outputStream = new PartitionedStream<TOutput, Pair<TLeftKey, int>>(partitionCount, keyComparer, OrdinalIndexState); 166PartitionedStream<TLeftInput, int> inputStream, IPartitionedStreamRecipient<TOutput> recipient, QuerySettings settings) 170var outputStream = new PartitionedStream<TOutput, Pair<int, int>>(inputStream.PartitionCount, keyComparer, OrdinalIndexState);

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

50PartitionedStream<TInput, TKey> inputStream, IPartitionedStreamRecipient<TOutput> recipient, bool preferStriping, QuerySettings settings) 52PartitionedStream<TOutput, TKey> outputStream =

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

56PartitionedStream<TSource, TKey> inputStream, IPartitionedStreamRecipient<TSource> recipient, bool preferStriping, QuerySettings settings) 59PartitionedStream<TSource, int> outputStream = new PartitionedStream<TSource, int>(

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

84PartitionedStream<TInputOutput, TKey> inputStream, IPartitionedStreamRecipient<TInputOutput> recipient, bool preferStriping, QuerySettings settings) 86PartitionedStream<TInputOutput, TSortKey> outputStream = 157public void Receive<TKey>(PartitionedStream<TInputOutput, TKey> childPartitionedStream)

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

87PartitionedStream<TResult, TKey> inputStream, IPartitionedStreamRecipient<TResult> recipient, bool preferStriping, QuerySettings settings) 96PartitionedStream<TResult, int> inputIntStream = results.GetPartitionedStream(); 105private void WrapHelper<TKey>(PartitionedStream<TResult, TKey> inputStream, IPartitionedStreamRecipient<TResult> recipient, QuerySettings settings) 114PartitionedStream<TResult, TKey> outputStream =

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

113PartitionedStream<TResult, TKey> inputStream, IPartitionedStreamRecipient<TResult> recipient, bool preferStriping, QuerySettings settings) 118PartitionedStream<TResult, int> listInputStream = results.GetPartitionedStream(); 127private void WrapHelper<TKey>(PartitionedStream<TResult, TKey> inputStream, IPartitionedStreamRecipient<TResult> recipient, QuerySettings settings) 140PartitionedStream<TResult, TKey> partitionedStream =

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

51PartitionedStream<TInputOutput, TKey> inputStream, IPartitionedStreamRecipient<TInputOutput> recipient, bool preferStriping, QuerySettings settings) 53PartitionedStream<TInputOutput, TKey> outputStream = new PartitionedStream<TInputOutput, TKey>(

System\Linq\Parallel\QueryOperators\UnaryQueryOperator.cs (4)

84PartitionedStream<TInput, TKey> inputStream, IPartitionedStreamRecipient<TOutput> recipient, 117PartitionedStream<TOutput, int> result = ExchangeUtilities.PartitionDataSource( 124PartitionedStream<TOutput, int> result = ExchangeUtilities.PartitionDataSource(this, _settings.DegreeOfParallelism.Value, _preferStriping); 157public void Receive<TKey>(PartitionedStream<TInput, TKey> inputStream)

System\Linq\Parallel\Scheduling\OrderPreservingPipeliningSpoolingTask.cs (1)

148QueryTaskGroupState groupState, PartitionedStream<TOutput, TKey> partitions,

System\Linq\Parallel\Scheduling\OrderPreservingSpoolingTask.cs (1)

71QueryTaskGroupState groupState, PartitionedStream<TInputOutput, TKey> partitions,

System\Linq\Parallel\Scheduling\SpoolingTask.cs (3)

33QueryTaskGroupState groupState, PartitionedStream<TInputOutput, TIgnoreKey> partitions, 89QueryTaskGroupState groupState, PartitionedStream<TInputOutput, TIgnoreKey> partitions, 134QueryTaskGroupState groupState, PartitionedStream<TInputOutput, TIgnoreKey> partitions, TaskScheduler taskScheduler)

System\Linq\Parallel\Utils\ExchangeUtilities.cs (7)

32internal static PartitionedStream<T, int> PartitionDataSource<T>(IEnumerable<T> source, int partitionCount, bool useStriping) 35PartitionedStream<T, int> returnValue; 52PartitionedStream<T, int> stream = 89internal static PartitionedStream<Pair<TElement, THashKey>, int> HashRepartition<TElement, THashKey, TIgnoreKey>( 90PartitionedStream<TElement, TIgnoreKey> source, Func<TElement, THashKey>? keySelector, IEqualityComparer<THashKey>? keyComparer, 97internal static PartitionedStream<Pair<TElement, THashKey>, TOrderKey> HashRepartitionOrdered<TElement, THashKey, TOrderKey>( 98PartitionedStream<TElement, TOrderKey> source, Func<TElement, THashKey>? keySelector, IEqualityComparer<THashKey>? keyComparer,

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

102PartitionedStream<TInputOutput, TKey> partitions, QueryTaskGroupState groupState)