5 writes to m_partitions
System.Core (5)
System\Linq\Parallel\Partitioning\OrderedHashRepartitionStream.cs (1)
26
m_partitions
=
System\Linq\Parallel\Partitioning\PartitionedDataSource.cs (2)
146
m_partitions
= partitions;
152
m_partitions
= MakePartitions(source.GetEnumerator(), partitionCount);
System\Linq\Parallel\Partitioning\PartitionedStream.cs (1)
45
m_partitions
= new QueryOperatorEnumerator<TElement, TKey>[partitionCount];
System\Linq\Parallel\Partitioning\UnorderedHashRepartitionStream.cs (1)
33
m_partitions
= new HashRepartitionEnumerator<TInputOutput, THashKey, TIgnoreKey>[inputStream.PartitionCount];
10 references to m_partitions
System.Core (10)
System\Linq\Parallel\Partitioning\OrderedHashRepartitionStream.cs (1)
39
m_partitions
[i] = new OrderedHashRepartitionEnumerator<TInputOutput, THashKey, TOrderKey>(
System\Linq\Parallel\Partitioning\PartitionedStream.cs (8)
61
Contract.Assert(
m_partitions
!= null);
62
Contract.Assert(0 <= index && index <
m_partitions
.Length, "index out of bounds");
63
return
m_partitions
[index];
67
Contract.Assert(
m_partitions
!= null);
69
Contract.Assert(0 <= index && index <
m_partitions
.Length, "index out of bounds");
70
m_partitions
[index] = value;
82
Contract.Assert(
m_partitions
!= null);
83
return
m_partitions
.Length;
System\Linq\Parallel\Partitioning\UnorderedHashRepartitionStream.cs (1)
44
m_partitions
[i] = new HashRepartitionEnumerator<TInputOutput, THashKey, TIgnoreKey>(