7 references to PartitionDataSource
System.Linq.Parallel (7)
System\Linq\Parallel\QueryOperators\Binary\ZipQueryOperator.cs (1)
204
PartitionedStream<TOutput, int> partitionedStream = ExchangeUtilities.
PartitionDataSource
(this, _partitionCount, _preferStriping);
System\Linq\Parallel\QueryOperators\BinaryQueryOperator.cs (2)
113
PartitionedStream<TOutput, int> result = ExchangeUtilities.
PartitionDataSource
(
121
PartitionedStream<TOutput, int> result = ExchangeUtilities.
PartitionDataSource
(this, _settings.DegreeOfParallelism.Value, _preferStriping);
System\Linq\Parallel\QueryOperators\ListQueryResults.cs (1)
54
return ExchangeUtilities.
PartitionDataSource
(_source, _partitionCount, _useStriping);
System\Linq\Parallel\QueryOperators\ScanQueryOperator.cs (1)
133
PartitionedStream<TElement, int> partitionedStream = ExchangeUtilities.
PartitionDataSource
(
System\Linq\Parallel\QueryOperators\UnaryQueryOperator.cs (2)
117
PartitionedStream<TOutput, int> result = ExchangeUtilities.
PartitionDataSource
(
124
PartitionedStream<TOutput, int> result = ExchangeUtilities.
PartitionDataSource
(this, _settings.DegreeOfParallelism.Value, _preferStriping);