5 writes to _partitions
System.Linq.Parallel (5)
System\Linq\Parallel\Partitioning\OrderedHashRepartitionStream.cs (1)
22
_partitions
=
System\Linq\Parallel\Partitioning\PartitionedDataSource.cs (2)
139
_partitions
= partitions;
145
_partitions
= MakePartitions(source.GetEnumerator(), partitionCount);
System\Linq\Parallel\Partitioning\PartitionedStream.cs (1)
41
_partitions
= new QueryOperatorEnumerator<TElement, TKey>[partitionCount];
System\Linq\Parallel\Partitioning\UnorderedHashRepartitionStream.cs (1)
28
_partitions
= new HashRepartitionEnumerator<TInputOutput, THashKey, TIgnoreKey>[inputStream.PartitionCount];
10 references to _partitions
System.Linq.Parallel (10)
System\Linq\Parallel\Partitioning\OrderedHashRepartitionStream.cs (1)
36
_partitions
[i] = new OrderedHashRepartitionEnumerator<TInputOutput, THashKey, TOrderKey>(
System\Linq\Parallel\Partitioning\PartitionedStream.cs (8)
57
Debug.Assert(
_partitions
!= null);
58
Debug.Assert(0 <= index && index <
_partitions
.Length, "index out of bounds");
59
return
_partitions
[index];
63
Debug.Assert(
_partitions
!= null);
65
Debug.Assert(0 <= index && index <
_partitions
.Length, "index out of bounds");
66
_partitions
[index] = value;
78
Debug.Assert(
_partitions
!= null);
79
return
_partitions
.Length;
System\Linq\Parallel\Partitioning\UnorderedHashRepartitionStream.cs (1)
39
_partitions
[i] = new HashRepartitionEnumerator<TInputOutput, THashKey, TIgnoreKey>(