7 references to PartitionDataSource
System.Core (7)
System\Linq\Parallel\QueryOperators\Binary\ZipQueryOperator.cs (1)
205
PartitionedStream<TOutput, int> partitionedStream = ExchangeUtilities.
PartitionDataSource
(this, m_partitionCount, m_preferStriping);
System\Linq\Parallel\QueryOperators\BinaryQueryOperator.cs (2)
115
PartitionedStream<TOutput, int> result = ExchangeUtilities.
PartitionDataSource
(
122
PartitionedStream<TOutput, int> result = ExchangeUtilities.
PartitionDataSource
(this, m_settings.DegreeOfParallelism.Value, m_preferStriping);
System\Linq\Parallel\QueryOperators\ListQueryResults.cs (1)
58
return ExchangeUtilities.
PartitionDataSource
(m_source, m_partitionCount, m_useStriping);
System\Linq\Parallel\QueryOperators\ScanQueryOperator.cs (1)
139
PartitionedStream<TElement, int> partitionedStream = ExchangeUtilities.
PartitionDataSource
(
System\Linq\Parallel\QueryOperators\UnaryQueryOperator.cs (2)
121
PartitionedStream<TOutput, int> result = ExchangeUtilities.
PartitionDataSource
(
128
PartitionedStream<TOutput, int> result = ExchangeUtilities.
PartitionDataSource
(this, m_settings.DegreeOfParallelism.Value, m_preferStriping);