PartitionedStream

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

33private PartitionedStream<TInputOutput, TIgnoreKey> m_partitions; // Source partitions. 49internal DefaultMergeHelper(PartitionedStream<TInputOutput, TIgnoreKey> partitions, bool ignoreOutput, ParallelMergeOptions options,

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

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

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

30private PartitionedStream<TInputOutput, TKey> m_partitions; // Source partitions. 42internal OrderPreservingMergeHelper(PartitionedStream<TInputOutput, TKey> partitions, TaskScheduler taskScheduler,

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

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

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

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

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

22PartitionedStream<TInputOutput, TOrderKey> inputStream, Func<TInputOutput, THashKey> hashKeySelector,

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

27PartitionedStream<TInputOutput, TIgnoreKey> inputStream,

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

199PartitionedStream<TInput, TKey> inputStream, IPartitionedStreamRecipient<TIntermediate> recipient, 203PartitionedStream<TIntermediate, int> outputStream = new PartitionedStream<TIntermediate, int>(

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

57PartitionedStream<TInputOutput, TLeftKey> leftStream, PartitionedStream<TInputOutput, TRightKey> rightStream, 84PartitionedStream<Pair<TInputOutput, NoKeyMemoizationRequired>, TLeftKey> leftHashStream, PartitionedStream<TInputOutput, TRightKey> rightPartitionedStream, 89PartitionedStream<Pair<TInputOutput, NoKeyMemoizationRequired>, int> rightHashStream = 93PartitionedStream<TInputOutput, TLeftKey> outputStream =

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

77PartitionedStream<TLeftInput, TLeftKey> leftStream, PartitionedStream<TRightInput, TRightKey> rightStream, 103PartitionedStream<Pair<TLeftInput, TKey>, TLeftKey> leftHashStream, PartitionedStream<TRightInput, TRightKey> rightPartitionedStream, 106PartitionedStream<Pair<TRightInput, TKey>, int> rightHashStream = ExchangeUtilities.HashRepartition( 109PartitionedStream<TOutput, TLeftKey> outputStream = new PartitionedStream<TOutput, TLeftKey>(

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

59PartitionedStream<TInputOutput, TLeftKey> leftPartitionedStream, PartitionedStream<TInputOutput, TRightKey> rightPartitionedStream, 86PartitionedStream<Pair<TInputOutput, NoKeyMemoizationRequired>, TLeftKey> leftHashStream, PartitionedStream<TInputOutput, TRightKey> rightPartitionedStream, 91PartitionedStream<Pair<TInputOutput, NoKeyMemoizationRequired>, int> rightHashStream = 95PartitionedStream<TInputOutput, TLeftKey> outputStream =

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

80PartitionedStream<TLeftInput, TLeftKey> leftStream, PartitionedStream<TRightInput, TRightKey> rightStream, 105PartitionedStream<Pair<TLeftInput, TKey>, TLeftKey> leftHashStream, PartitionedStream<TRightInput, TRightKey> rightPartitionedStream, 109PartitionedStream<Pair<TRightInput, TKey>, int> rightHashStream = ExchangeUtilities.HashRepartition( 112PartitionedStream<TOutput, TLeftKey> outputStream = new PartitionedStream<TOutput, TLeftKey>(

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

61PartitionedStream<TInputOutput, TLeftKey> leftStream, PartitionedStream<TInputOutput, TRightKey> rightStream, 71PartitionedStream<Pair<TInputOutput, NoKeyMemoizationRequired>, TLeftKey> leftHashStream = 80PartitionedStream<Pair<TInputOutput, NoKeyMemoizationRequired>, int> leftHashStream = 94PartitionedStream<Pair<TInputOutput, NoKeyMemoizationRequired>, TLeftKey> leftHashStream, PartitionedStream<TInputOutput, TRightKey> rightStream, 99PartitionedStream<Pair<TInputOutput, NoKeyMemoizationRequired>, TRightKey> rightHashStream = 108PartitionedStream<Pair<TInputOutput, NoKeyMemoizationRequired>, int> rightHashStream = 122PartitionedStream<Pair<TInputOutput, NoKeyMemoizationRequired>, TLeftKey> leftHashStream, 123PartitionedStream<Pair<TInputOutput, NoKeyMemoizationRequired>, TRightKey> rightHashStream, 132PartitionedStream<TInputOutput, ConcatKey<TLeftKey, TRightKey>> outputStream = 146PartitionedStream<TInputOutput, int> outputStream =

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

205PartitionedStream<TOutput, int> partitionedStream = ExchangeUtilities.PartitionDataSource(this, m_partitionCount, m_preferStriping);

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

79PartitionedStream<TLeftInput, TLeftKey> leftPartitionedStream, PartitionedStream<TRightInput, TRightKey> rightPartitionedStream, 115PartitionedStream<TOutput, int> result = ExchangeUtilities.PartitionDataSource( 122PartitionedStream<TOutput, int> result = ExchangeUtilities.PartitionDataSource(this, m_settings.DegreeOfParallelism.Value, m_preferStriping); 154public void Receive<TLeftKey>(PartitionedStream<TLeftInput, TLeftKey> source) 174PartitionedStream<TLeftInput, TLeftKey> m_leftPartitionedStream; 181PartitionedStream<TLeftInput, TLeftKey> leftPartitionedStream, bool preferStriping, QuerySettings settings) 190public void Receive<TRightKey>(PartitionedStream<TRightInput, TRightKey> rightPartitionedStream)

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

130PartitionedStream<TSource, TKey> inputStream, IPartitionedStreamRecipient<TIntermediate> recipient, 134PartitionedStream<TIntermediate, int> outputStream = new PartitionedStream<TIntermediate, int>(

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

37PartitionedStream<T, int> partitionedStream = GetPartitionedStream(); 56internal PartitionedStream<T, int> GetPartitionedStream()

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

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

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

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

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

274PartitionedStream<TOutput, TKey> openedChild,

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

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

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

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

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

81PartitionedStream<TSource, TLeftKey> leftStream, PartitionedStream<TSource, TRightKey> rightStream, 89PartitionedStream<TSource, int> leftStreamInc = leftStreamResults.GetPartitionedStream(); 100PartitionedStream<TSource, TLeftKey> leftStreamInc, PartitionedStream<TSource, TRightKey> rightStream, 108PartitionedStream<TSource, int> rightStreamInc = rightStreamResults.GetPartitionedStream(); 119PartitionedStream<TSource, TLeftKey> leftStreamInc, PartitionedStream<TSource, TRightKey> rightStreamInc, 127var outputStream = new PartitionedStream<TSource, ConcatKey<TLeftKey, TRightKey>>(partitionCount, comparer, OrdinalIndexState);

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

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

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

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

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

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

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

70PartitionedStream<TSource,TKey> inputStream, IPartitionedStreamRecipient<TSource> recipient, bool preferStriping, QuerySettings settings) 75PartitionedStream<TSource, int> intKeyStream; 83intKeyStream = (PartitionedStream<TSource, int>)(object)inputStream; 89PartitionedStream<TSource, int> outputStream = new PartitionedStream<TSource, int>(

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

61PartitionedStream<TSource, TKey> inputStream, IPartitionedStreamRecipient<TSource> recipient, bool preferStriping, QuerySettings settings) 76PartitionedStream<TSource, TKey> inputStream, IPartitionedStreamRecipient<TSource> recipient, QuerySettings settings) 84PartitionedStream<TSource, int> outputStream = new PartitionedStream<TSource, int>(

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

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

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

73PartitionedStream<TSource, TKey> inputStream, IPartitionedStreamRecipient<IGrouping<TGroupKey, TElement>> recipient, 103PartitionedStream<Pair<TSource, TGroupKey>, TKey> hashStream, 108PartitionedStream<IGrouping<TGroupKey, TElement>, TKey> outputStream = 142PartitionedStream<Pair<TSource, TGroupKey>, TKey> hashStream, 147PartitionedStream<IGrouping<TGroupKey, TElement>, TKey> outputStream =

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

93PartitionedStream<TInput, TKey> inputStream, IPartitionedStreamRecipient<TOutput> recipient, bool preferStriping, QuerySettings settings) 98PartitionedStream<TInput, int> inputStreamInt; 108inputStreamInt = (PartitionedStream<TInput, int>)(object)inputStream; 112PartitionedStream<TOutput, int> outputStream =

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

88PartitionedStream<TInputOutput, TKey> inputStream, IPartitionedStreamRecipient<TInputOutput> recipient, bool preferStriping, QuerySettings settings) 93PartitionedStream<TInputOutput, int> inputStreamInt; 102inputStreamInt = (PartitionedStream<TInputOutput, int>)(object)inputStream; 106PartitionedStream<TInputOutput, int> outputStream =

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

61PartitionedStream<TSource, TKey> inputStream, IPartitionedStreamRecipient<TSource> recipient, bool preferStriping, QuerySettings settings) 66PartitionedStream<TSource, int> intKeyStream = 76private void WrapHelper<TKey>(PartitionedStream<TSource, TKey> inputStream, IPartitionedStreamRecipient<TSource> recipient, QuerySettings settings) 84PartitionedStream<TSource, int> outputStream =

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

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

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

108PartitionedStream<TLeftInput, TLeftKey> inputStream, IPartitionedStreamRecipient<TOutput> recipient, bool preferStriping, QuerySettings settings) 114PartitionedStream<TLeftInput, int> inputStreamInt; 125inputStreamInt = (PartitionedStream<TLeftInput, int>)(object)inputStream; 135PartitionedStream<TLeftInput, int> inputStreamInt = 152PartitionedStream<TLeftInput, TLeftKey> inputStream, IPartitionedStreamRecipient<TOutput> recipient, QuerySettings settings) 156var outputStream = new PartitionedStream<TOutput, Pair<TLeftKey, int>>(partitionCount, keyComparer, OrdinalIndexState); 170PartitionedStream<TLeftInput, int> inputStream, IPartitionedStreamRecipient<TOutput> recipient, QuerySettings settings) 174var outputStream = new PartitionedStream<TOutput, Pair<int, int>>(inputStream.PartitionCount, keyComparer, OrdinalIndexState);

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

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

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

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

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

113PartitionedStream<TInputOutput, TKey> inputStream, IPartitionedStreamRecipient<TInputOutput> recipient, bool preferStriping, QuerySettings settings) 115PartitionedStream<TInputOutput, TSortKey> outputStream = 188public void Receive<TKey>(PartitionedStream<TInputOutput, TKey> childPartitionedStream)

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

91PartitionedStream<TResult, TKey> inputStream, IPartitionedStreamRecipient<TResult> recipient, bool preferStriping, QuerySettings settings) 100PartitionedStream<TResult, int> inputIntStream = results.GetPartitionedStream(); 109private void WrapHelper<TKey>(PartitionedStream<TResult, TKey> inputStream, IPartitionedStreamRecipient<TResult> recipient, QuerySettings settings) 115PartitionedStream<TResult, TKey> outputStream =

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

117PartitionedStream<TResult, TKey> inputStream, IPartitionedStreamRecipient<TResult> recipient, bool preferStriping, QuerySettings settings) 123PartitionedStream<TResult, int> listInputStream = results.GetPartitionedStream(); 134private void WrapHelper<TKey>(PartitionedStream<TResult, TKey> inputStream, IPartitionedStreamRecipient<TResult> recipient, QuerySettings settings) 145PartitionedStream<TResult, TKey> partitionedStream =

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

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

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

89PartitionedStream<TInput, TKey> inputStream, IPartitionedStreamRecipient<TOutput> recipient, 121PartitionedStream<TOutput, int> result = ExchangeUtilities.PartitionDataSource( 128PartitionedStream<TOutput, int> result = ExchangeUtilities.PartitionDataSource(this, m_settings.DegreeOfParallelism.Value, m_preferStriping); 161public void Receive<TKey>(PartitionedStream<TInput, TKey> inputStream)

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

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

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

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

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

38QueryTaskGroupState groupState, PartitionedStream<TInputOutput, TIgnoreKey> partitions, 91QueryTaskGroupState groupState, PartitionedStream<TInputOutput, TIgnoreKey> partitions, 137QueryTaskGroupState groupState, PartitionedStream<TInputOutput, TIgnoreKey> partitions, TaskScheduler taskScheduler)

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

39internal static PartitionedStream<T, int> PartitionDataSource<T>(IEnumerable<T> source, int partitionCount, bool useStriping) 42PartitionedStream<T, int> returnValue; 60PartitionedStream<T, int> stream = 97internal static PartitionedStream<Pair<TElement, THashKey>, int> HashRepartition<TElement, THashKey, TIgnoreKey>( 98PartitionedStream<TElement, TIgnoreKey> source, Func<TElement, THashKey> keySelector, IEqualityComparer<THashKey> keyComparer, 105internal static PartitionedStream<Pair<TElement, THashKey>, TOrderKey> HashRepartitionOrdered<TElement, THashKey, TOrderKey>( 106PartitionedStream<TElement, TOrderKey> source, Func<TElement, THashKey> keySelector, IEqualityComparer<THashKey> keyComparer,

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

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