PartitionDataSource< T >()

static PartitionedStream< T, int > System.Linq.Parallel.ExchangeUtilities.PartitionDataSource< T > ( IEnumerable< T > source, int partitionCount, bool useStriping )

inlinestaticpackage

Definition at line 8 of file ExchangeUtilities.cs.

    {
        if (source is IParallelPartitionable<T> parallelPartitionable)
        {
            QueryOperatorEnumerator<T, int>[] partitions = parallelPartitionable.GetPartitions(partitionCount);
            if (partitions == null)
            {
                throw new InvalidOperationException(System.SR.ParallelPartitionable_NullReturn);
            }
            if (partitions.Length != partitionCount)
            {
                throw new InvalidOperationException(System.SR.ParallelPartitionable_IncorretElementCount);
            }
            PartitionedStream<T, int> partitionedStream = new PartitionedStream<T, int>(partitionCount, Util.GetDefaultComparer<int>(), OrdinalIndexState.Correct);
            for (int i = 0; i < partitionCount; i++)
            {
                QueryOperatorEnumerator<T, int> queryOperatorEnumerator = partitions[i];
                if (queryOperatorEnumerator == null)
                {
                    throw new InvalidOperationException(System.SR.ParallelPartitionable_NullElement);
                }
                partitionedStream[i] = queryOperatorEnumerator;
            }
            return partitionedStream;
        }
        return new PartitionedDataSource<T>(source, partitionCount, useStriping);
    }

References System.SR.ParallelPartitionable_IncorretElementCount, System.SR.ParallelPartitionable_NullElement, System.SR.ParallelPartitionable_NullReturn, and System.Linq.source.