44 types derived from QueryOperatorEnumerator
System.Core (44)
System\Linq\Parallel\Enumerables\EmptyEnumerable.cs (1)
62internal class EmptyEnumerator<T> : QueryOperatorEnumerator<T, int>, IEnumerator<T>
System\Linq\Parallel\Enumerables\RangeEnumerable.cs (1)
79class RangeEnumerator : QueryOperatorEnumerator<int, int>
System\Linq\Parallel\Enumerables\RepeatEnumerable.cs (1)
84class RepeatEnumerator : QueryOperatorEnumerator<TResult, int>
System\Linq\Parallel\Partitioning\HashRepartitionEnumerator.cs (1)
27internal class HashRepartitionEnumerator<TInputOutput, THashKey, TIgnoreKey> : QueryOperatorEnumerator<Pair<TInputOutput, THashKey>, int>
System\Linq\Parallel\Partitioning\OrderedHashRepartitionEnumerator.cs (1)
28internal class OrderedHashRepartitionEnumerator<TInputOutput, THashKey, TOrderKey> : QueryOperatorEnumerator<Pair<TInputOutput, THashKey>, TOrderKey>
System\Linq\Parallel\Partitioning\PartitionedDataSource.cs (5)
219internal sealed class ArrayIndexRangeEnumerator : QueryOperatorEnumerator<T, int> 342internal sealed class ArrayContiguousIndexRangeEnumerator : QueryOperatorEnumerator<T, int> 397internal sealed class ListIndexRangeEnumerator : QueryOperatorEnumerator<T, int> 520internal sealed class ListContiguousIndexRangeEnumerator : QueryOperatorEnumerator<T, int> 579private class ContiguousChunkLazyEnumerator : QueryOperatorEnumerator<T, int>
System\Linq\Parallel\QueryOperators\AssociativeAggregationOperator.cs (1)
241private class AssociativeAggregationOperatorEnumerator<TKey> : QueryOperatorEnumerator<TIntermediate, int>
System\Linq\Parallel\QueryOperators\Binary\ExceptQueryOperator.cs (2)
141class ExceptQueryOperatorEnumerator<TLeftKey> : QueryOperatorEnumerator<TInputOutput, int> 230class OrderedExceptQueryOperatorEnumerator<TLeftKey> : QueryOperatorEnumerator<TInputOutput, TLeftKey>
System\Linq\Parallel\QueryOperators\Binary\HashJoinQueryOperatorEnumerator.cs (1)
40: QueryOperatorEnumerator<TOutput,TLeftKey>
System\Linq\Parallel\QueryOperators\Binary\IntersectQueryOperator.cs (2)
130class IntersectQueryOperatorEnumerator<TLeftKey> : QueryOperatorEnumerator<TInputOutput, int> 233class OrderedIntersectQueryOperatorEnumerator<TLeftKey> : QueryOperatorEnumerator<TInputOutput, TLeftKey>
System\Linq\Parallel\QueryOperators\Binary\UnionQueryOperator.cs (2)
187class UnionQueryOperatorEnumerator<TLeftKey, TRightKey> : QueryOperatorEnumerator<TInputOutput, int> 304class OrderedUnionQueryOperatorEnumerator<TLeftKey, TRightKey> : QueryOperatorEnumerator<TInputOutput, ConcatKey<TLeftKey, TRightKey>>
System\Linq\Parallel\QueryOperators\Inlined\InlinedAggregationOperatorEnumerator.cs (1)
35internal abstract class InlinedAggregationOperatorEnumerator<TIntermediate> : QueryOperatorEnumerator<TIntermediate, int>
System\Linq\Parallel\QueryOperators\PartitionerQueryOperator.cs (2)
214private class OrderablePartitionerEnumerator : QueryOperatorEnumerator<TElement, int> 249private class PartitionerEnumerator : QueryOperatorEnumerator<TElement, int>
System\Linq\Parallel\QueryOperators\Unary\AnyAllSearchOperator.cs (1)
152private class AnyAllSearchOperatorEnumerator<TKey> : QueryOperatorEnumerator<bool, int>
System\Linq\Parallel\QueryOperators\Unary\ConcatQueryOperator.cs (1)
162class ConcatQueryOperatorEnumerator<TLeftKey, TRightKey> : QueryOperatorEnumerator<TSource, ConcatKey<TLeftKey, TRightKey>>
System\Linq\Parallel\QueryOperators\Unary\ContainsSearchOperator.cs (1)
139class ContainsSearchOperatorEnumerator<TKey> : QueryOperatorEnumerator<bool, int>
System\Linq\Parallel\QueryOperators\Unary\DefaultIfEmptyQueryOperator.cs (1)
106class DefaultIfEmptyQueryOperatorEnumerator<TKey> : QueryOperatorEnumerator<TSource, TKey>
System\Linq\Parallel\QueryOperators\Unary\DistinctQueryOperator.cs (2)
123class DistinctQueryOperatorEnumerator<TKey> : QueryOperatorEnumerator<TInputOutput, int> 197class OrderedDistinctQueryOperatorEnumerator<TKey> : QueryOperatorEnumerator<TInputOutput, TKey>
System\Linq\Parallel\QueryOperators\Unary\ElementAtQueryOperator.cs (1)
170class ElementAtQueryOperatorEnumerator : QueryOperatorEnumerator<TSource, int>
System\Linq\Parallel\QueryOperators\Unary\FirstQueryOperator.cs (1)
122class FirstQueryOperatorEnumerator<TKey> : QueryOperatorEnumerator<TSource, int>
System\Linq\Parallel\QueryOperators\Unary\ForAllOperator.cs (1)
127private class ForAllEnumerator<TKey> : QueryOperatorEnumerator<TInput, int>
System\Linq\Parallel\QueryOperators\Unary\GroupByQueryOperator.cs (2)
228QueryOperatorEnumerator<IGrouping<TGroupKey, TElement>, TOrderKey> 433QueryOperatorEnumerator<IGrouping<TGroupKey, TElement>, TOrderKey>
System\Linq\Parallel\QueryOperators\Unary\IndexedSelectQueryOperator.cs (1)
138class IndexedSelectQueryOperatorEnumerator : QueryOperatorEnumerator<TOutput, int>
System\Linq\Parallel\QueryOperators\Unary\IndexedWhereQueryOperator.cs (1)
143private class IndexedWhereQueryOperatorEnumerator : QueryOperatorEnumerator<TInputOutput, int>
System\Linq\Parallel\QueryOperators\Unary\LastQueryOperator.cs (1)
118class LastQueryOperatorEnumerator<TKey> : QueryOperatorEnumerator<TSource, int>
System\Linq\Parallel\QueryOperators\Unary\ReverseQueryOperator.cs (1)
109class ReverseQueryOperatorEnumerator<TKey> : QueryOperatorEnumerator<TSource, TKey>
System\Linq\Parallel\QueryOperators\Unary\SelectManyQueryOperator.cs (2)
237class IndexedSelectManyQueryOperatorEnumerator : QueryOperatorEnumerator<TOutput, Pair<int, int>> 367class SelectManyQueryOperatorEnumerator<TLeftKey> : QueryOperatorEnumerator<TOutput, Pair<TLeftKey, int>>
System\Linq\Parallel\QueryOperators\Unary\SelectQueryOperator.cs (1)
97class SelectQueryOperatorEnumerator<TKey> : QueryOperatorEnumerator<TOutput, TKey>
System\Linq\Parallel\QueryOperators\Unary\SingleQueryOperator.cs (1)
99class SingleQueryOperatorEnumerator<TKey> : QueryOperatorEnumerator<TSource, int>
System\Linq\Parallel\QueryOperators\Unary\SortQueryOperator.cs (1)
199internal class SortQueryOperatorEnumerator<TInputOutput, TKey, TSortKey> : QueryOperatorEnumerator<TInputOutput, TSortKey>
System\Linq\Parallel\QueryOperators\Unary\TakeOrSkipQueryOperator.cs (1)
152class TakeOrSkipQueryOperatorEnumerator<TKey> : QueryOperatorEnumerator<TResult, TKey>
System\Linq\Parallel\QueryOperators\Unary\TakeOrSkipWhileQueryOperator.cs (1)
208class TakeOrSkipWhileQueryOperatorEnumerator<TKey> : QueryOperatorEnumerator<TResult, TKey>
System\Linq\Parallel\QueryOperators\Unary\WhereQueryOperator.cs (1)
106private class WhereQueryOperatorEnumerator<TKey> : QueryOperatorEnumerator<TInputOutput, TKey>
286 references to QueryOperatorEnumerator
System.Core (286)
System\Linq\Parallel\Enumerables\IParallelPartitionable.cs (1)
24QueryOperatorEnumerator<T, int>[] GetPartitions(int partitionCount);
System\Linq\Parallel\Enumerables\RangeEnumerable.cs (3)
44public QueryOperatorEnumerator<int, int>[] GetPartitions(int partitionCount) 52QueryOperatorEnumerator<int, int>[] partitions = new QueryOperatorEnumerator<int, int>[partitionCount];
System\Linq\Parallel\Enumerables\RepeatEnumerable.cs (3)
47public QueryOperatorEnumerator<TResult, int>[] GetPartitions(int partitionCount) 55QueryOperatorEnumerator<TResult, int>[] partitions = new QueryOperatorEnumerator<TResult, int>[partitionCount];
System\Linq\Parallel\Partitioning\HashRepartitionEnumerator.cs (2)
37private readonly QueryOperatorEnumerator<TInputOutput, TIgnoreKey> m_source; // The immediate source of data. 68QueryOperatorEnumerator<TInputOutput, TIgnoreKey> source, int partitionCount, int partitionIndex,
System\Linq\Parallel\Partitioning\OrderedHashRepartitionEnumerator.cs (2)
38private readonly QueryOperatorEnumerator<TInputOutput, TOrderKey> m_source; // The immediate source of data. 70QueryOperatorEnumerator<TInputOutput, TOrderKey> source, int partitionCount, int partitionIndex,
System\Linq\Parallel\Partitioning\PartitionedDataSource.cs (5)
93QueryOperatorEnumerator<T, int>[] partitions = new QueryOperatorEnumerator<T, int>[partitionCount]; 166private static QueryOperatorEnumerator<T, int>[] MakePartitions(IEnumerator<T> source, int partitionCount) 173QueryOperatorEnumerator<T, int>[] partitions = new QueryOperatorEnumerator<T, int>[partitionCount];
System\Linq\Parallel\Partitioning\PartitionedStream.cs (3)
38protected QueryOperatorEnumerator<TElement, TKey>[] m_partitions; // Partitions exposed by this object. 45m_partitions = new QueryOperatorEnumerator<TElement, TKey>[partitionCount]; 57internal QueryOperatorEnumerator<TElement, TKey> this[int index]
System\Linq\Parallel\QueryOperators\AssociativeAggregationOperator.cs (2)
243private readonly QueryOperatorEnumerator<TInput, TKey> m_source; // The source data. 254internal AssociativeAggregationOperatorEnumerator(QueryOperatorEnumerator<TInput, TKey> source,
System\Linq\Parallel\QueryOperators\Binary\ExceptQueryOperator.cs (9)
105outputStream[i] = (QueryOperatorEnumerator<TInputOutput, TLeftKey>)(object) 143private QueryOperatorEnumerator<Pair<TInputOutput, NoKeyMemoizationRequired>, TLeftKey> m_leftSource; // Left data source. 144private QueryOperatorEnumerator<Pair<TInputOutput, NoKeyMemoizationRequired>, int> m_rightSource; // Right data source. 155QueryOperatorEnumerator<Pair<TInputOutput, NoKeyMemoizationRequired>, TLeftKey> leftSource, 156QueryOperatorEnumerator<Pair<TInputOutput, NoKeyMemoizationRequired>, int> rightSource, 232private QueryOperatorEnumerator<Pair<TInputOutput, NoKeyMemoizationRequired>, TLeftKey> m_leftSource; // Left data source. 233private QueryOperatorEnumerator<Pair<TInputOutput, NoKeyMemoizationRequired>, int> m_rightSource; // Right data source. 244QueryOperatorEnumerator<Pair<TInputOutput, NoKeyMemoizationRequired>, TLeftKey> leftSource, 245QueryOperatorEnumerator<Pair<TInputOutput, NoKeyMemoizationRequired>, int> rightSource,
System\Linq\Parallel\QueryOperators\Binary\HashJoinQueryOperatorEnumerator.cs (4)
42private readonly QueryOperatorEnumerator<Pair<TLeftInput, THashKey>, TLeftKey> m_leftSource; // Left (outer) data source. For probing. 43private readonly QueryOperatorEnumerator<Pair<TRightInput, THashKey>, int> m_rightSource; // Right (inner) data source. For building. 65QueryOperatorEnumerator<Pair<TLeftInput, THashKey>, TLeftKey> leftSource, 66QueryOperatorEnumerator<Pair<TRightInput, THashKey>, int> rightSource,
System\Linq\Parallel\QueryOperators\Binary\IntersectQueryOperator.cs (9)
106outputStream[i] = (QueryOperatorEnumerator<TInputOutput, TLeftKey>)(object) 133private QueryOperatorEnumerator<Pair<TInputOutput, NoKeyMemoizationRequired>, TLeftKey> m_leftSource; // Left data source. 134private QueryOperatorEnumerator<Pair<TInputOutput, NoKeyMemoizationRequired>, int> m_rightSource; // Right data source. 145QueryOperatorEnumerator<Pair<TInputOutput, NoKeyMemoizationRequired>, TLeftKey> leftSource, 146QueryOperatorEnumerator<Pair<TInputOutput, NoKeyMemoizationRequired>, int> rightSource, 236private QueryOperatorEnumerator<Pair<TInputOutput, NoKeyMemoizationRequired>, TLeftKey> m_leftSource; // Left data source. 237private QueryOperatorEnumerator<Pair<TInputOutput, NoKeyMemoizationRequired>, int> m_rightSource; // Right data source. 248QueryOperatorEnumerator<Pair<TInputOutput, NoKeyMemoizationRequired>, TLeftKey> leftSource, 249QueryOperatorEnumerator<Pair<TInputOutput, NoKeyMemoizationRequired>, int> rightSource,
System\Linq\Parallel\QueryOperators\Binary\UnionQueryOperator.cs (8)
190private QueryOperatorEnumerator<Pair<TInputOutput, NoKeyMemoizationRequired>, TLeftKey> m_leftSource; // Left data source. 191private QueryOperatorEnumerator<Pair<TInputOutput, NoKeyMemoizationRequired>, TRightKey> m_rightSource; // Right data source. 203QueryOperatorEnumerator<Pair<TInputOutput, NoKeyMemoizationRequired>, TLeftKey> leftSource, 204QueryOperatorEnumerator<Pair<TInputOutput, NoKeyMemoizationRequired>, TRightKey> rightSource, 306private QueryOperatorEnumerator<Pair<TInputOutput, NoKeyMemoizationRequired>, TLeftKey> m_leftSource; // Left data source. 307private QueryOperatorEnumerator<Pair<TInputOutput, NoKeyMemoizationRequired>, TRightKey> m_rightSource; // Right data source. 320QueryOperatorEnumerator<Pair<TInputOutput, NoKeyMemoizationRequired>, TLeftKey> leftSource, 321QueryOperatorEnumerator<Pair<TInputOutput, NoKeyMemoizationRequired>, TRightKey> rightSource,
System\Linq\Parallel\QueryOperators\Inlined\CountAggregationOperator.cs (5)
69protected override QueryOperatorEnumerator<int, int> CreateEnumerator<TKey>( 70int index, int count, QueryOperatorEnumerator<TSource, TKey> source, object sharedData, 83private readonly QueryOperatorEnumerator<TSource, TKey> m_source; // The source data. 89internal CountAggregationOperatorEnumerator(QueryOperatorEnumerator<TSource, TKey> source, int partitionIndex, 107QueryOperatorEnumerator<TSource, TKey> source = m_source;
System\Linq\Parallel\QueryOperators\Inlined\DecimalAverageAggregationOperator.cs (5)
80protected override QueryOperatorEnumerator<Pair<decimal, long>, int> CreateEnumerator<TKey>( 81int index, int count, QueryOperatorEnumerator<decimal, TKey> source, object sharedData, CancellationToken cancellationToken) 93private QueryOperatorEnumerator<decimal, TKey> m_source; // The source data. 99internal DecimalAverageAggregationOperatorEnumerator(QueryOperatorEnumerator<decimal, TKey> source, int partitionIndex, 118QueryOperatorEnumerator<decimal, TKey> source = m_source;
System\Linq\Parallel\QueryOperators\Inlined\DecimalMinMaxAggregationOperator.cs (5)
97protected override QueryOperatorEnumerator<decimal, int> CreateEnumerator<TKey>( 98int index, int count, QueryOperatorEnumerator<decimal, TKey> source, object sharedData, CancellationToken cancellationToken) 110private QueryOperatorEnumerator<decimal, TKey> m_source; // The source data. 117internal DecimalMinMaxAggregationOperatorEnumerator(QueryOperatorEnumerator<decimal, TKey> source, int partitionIndex, int sign, 134QueryOperatorEnumerator<decimal, TKey> source = m_source;
System\Linq\Parallel\QueryOperators\Inlined\DecimalSumAggregationOperator.cs (5)
68protected override QueryOperatorEnumerator<decimal, int> CreateEnumerator<TKey>( 69int index, int count, QueryOperatorEnumerator<decimal, TKey> source, object sharedData, CancellationToken cancellationToken) 81private QueryOperatorEnumerator<decimal, TKey> m_source; // The source data. 87internal DecimalSumAggregationOperatorEnumerator(QueryOperatorEnumerator<decimal, TKey> source, int partitionIndex, 105QueryOperatorEnumerator<decimal, TKey> source = m_source;
System\Linq\Parallel\QueryOperators\Inlined\DoubleAverageAggregationOperator.cs (5)
79protected override QueryOperatorEnumerator<Pair<double, long>, int> CreateEnumerator<TKey>( 80int index, int count, QueryOperatorEnumerator<double, TKey> source, object sharedData, 93private QueryOperatorEnumerator<double, TKey> m_source; // The source data. 99internal DoubleAverageAggregationOperatorEnumerator(QueryOperatorEnumerator<double, TKey> source, int partitionIndex, 118QueryOperatorEnumerator<double, TKey> source = m_source;
System\Linq\Parallel\QueryOperators\Inlined\DoubleMinMaxAggregationOperator.cs (5)
102protected override QueryOperatorEnumerator<double, int> CreateEnumerator<TKey>( 103int index, int count, QueryOperatorEnumerator<double, TKey> source, object sharedData, 116private QueryOperatorEnumerator<double, TKey> m_source; // The source data. 123internal DoubleMinMaxAggregationOperatorEnumerator(QueryOperatorEnumerator<double, TKey> source, int partitionIndex, int sign, 140QueryOperatorEnumerator<double, TKey> source = m_source;
System\Linq\Parallel\QueryOperators\Inlined\DoubleSumAggregationOperator.cs (5)
70protected override QueryOperatorEnumerator<double,int> CreateEnumerator<TKey>( 71int index, int count, QueryOperatorEnumerator<double, TKey> source, object sharedData, CancellationToken cancellationToken) 83private readonly QueryOperatorEnumerator<double, TKey> m_source; // The source data. 89internal DoubleSumAggregationOperatorEnumerator(QueryOperatorEnumerator<double, TKey> source, int partitionIndex, 107QueryOperatorEnumerator<double, TKey> source = m_source;
System\Linq\Parallel\QueryOperators\Inlined\FloatAverageAggregationOperator.cs (5)
79protected override QueryOperatorEnumerator<Pair<double, long>, int> CreateEnumerator<TKey>( 80int index, int count, QueryOperatorEnumerator<float, TKey> source, object sharedData, 93private QueryOperatorEnumerator<float, TKey> m_source; // The source data. 99internal FloatAverageAggregationOperatorEnumerator(QueryOperatorEnumerator<float, TKey> source, int partitionIndex, 118QueryOperatorEnumerator<float, TKey> source = m_source;
System\Linq\Parallel\QueryOperators\Inlined\FloatMinMaxAggregationOperator.cs (5)
101protected override QueryOperatorEnumerator<float, int> CreateEnumerator<TKey>( 102int index, int count, QueryOperatorEnumerator<float, TKey> source, object sharedData, CancellationToken cancellationToken) 114private QueryOperatorEnumerator<float, TKey> m_source; // The source data. 121internal FloatMinMaxAggregationOperatorEnumerator(QueryOperatorEnumerator<float, TKey> source, int partitionIndex, int sign, 138QueryOperatorEnumerator<float, TKey> source = m_source;
System\Linq\Parallel\QueryOperators\Inlined\FloatSumAggregationOperator.cs (5)
71protected override QueryOperatorEnumerator<double,int> CreateEnumerator<TKey>( 72int index, int count, QueryOperatorEnumerator<float, TKey> source, object sharedData, 85private readonly QueryOperatorEnumerator<float, TKey> m_source; // The source data. 91internal FloatSumAggregationOperatorEnumerator(QueryOperatorEnumerator<float, TKey> source, int partitionIndex, 109QueryOperatorEnumerator<float, TKey> source = m_source;
System\Linq\Parallel\QueryOperators\Inlined\InlinedAggregationOperator.cs (2)
145protected abstract QueryOperatorEnumerator<TIntermediate, int> CreateEnumerator<TKey>( 146int index, int count, QueryOperatorEnumerator<TSource, TKey> source, object sharedData, CancellationToken cancellationToken);
System\Linq\Parallel\QueryOperators\Inlined\IntAverageAggregationOperator.cs (5)
80protected override QueryOperatorEnumerator<Pair<long, long>,int> CreateEnumerator<TKey>( 81int index, int count, QueryOperatorEnumerator<int, TKey> source, object sharedData, CancellationToken cancellationToken) 93private QueryOperatorEnumerator<int, TKey> m_source; // The source data. 99internal IntAverageAggregationOperatorEnumerator(QueryOperatorEnumerator<int, TKey> source, int partitionIndex, 118QueryOperatorEnumerator<int, TKey> source = m_source;
System\Linq\Parallel\QueryOperators\Inlined\IntMinMaxAggregationOperator.cs (5)
97protected override QueryOperatorEnumerator<int, int> CreateEnumerator<TKey>( 98int index, int count, QueryOperatorEnumerator<int, TKey> source, object sharedData, CancellationToken cancellationToken) 110private readonly QueryOperatorEnumerator<int, TKey> m_source; // The source data. 117internal IntMinMaxAggregationOperatorEnumerator(QueryOperatorEnumerator<int, TKey> source, int partitionIndex, int sign, 134QueryOperatorEnumerator<int, TKey> source = m_source;
System\Linq\Parallel\QueryOperators\Inlined\IntSumAggregationOperator.cs (5)
72protected override QueryOperatorEnumerator<int,int> CreateEnumerator<TKey>( 73int index, int count, QueryOperatorEnumerator<int, TKey> source, object sharedData, CancellationToken cancellationToken) 85private readonly QueryOperatorEnumerator<int, TKey> m_source; // The source data. 91internal IntSumAggregationOperatorEnumerator(QueryOperatorEnumerator<int, TKey> source, int partitionIndex, 109QueryOperatorEnumerator<int, TKey> source = m_source;
System\Linq\Parallel\QueryOperators\Inlined\LongAverageAggregationOperator.cs (5)
80protected override QueryOperatorEnumerator<Pair<long, long>, int> CreateEnumerator<TKey>( 81int index, int count, QueryOperatorEnumerator<long, TKey> source, object sharedData, CancellationToken cancellationToken) 93private QueryOperatorEnumerator<long, TKey> m_source; // The source data. 99internal LongAverageAggregationOperatorEnumerator(QueryOperatorEnumerator<long, TKey> source, int partitionIndex, 118QueryOperatorEnumerator<long, TKey> source = m_source;
System\Linq\Parallel\QueryOperators\Inlined\LongCountAggregationOperator.cs (5)
72protected override QueryOperatorEnumerator<long, int> CreateEnumerator<TKey>( 73int index, int count, QueryOperatorEnumerator<TSource, TKey> source, object sharedData, CancellationToken cancellationToken) 85private readonly QueryOperatorEnumerator<TSource, TKey> m_source; // The source data. 91internal LongCountAggregationOperatorEnumerator(QueryOperatorEnumerator<TSource, TKey> source, int partitionIndex, 109QueryOperatorEnumerator<TSource, TKey> source = m_source;
System\Linq\Parallel\QueryOperators\Inlined\LongMinMaxAggregationOperator.cs (5)
97protected override QueryOperatorEnumerator<long, int> CreateEnumerator<TKey>( 98int index, int count, QueryOperatorEnumerator<long, TKey> source, object sharedData, 111private QueryOperatorEnumerator<long, TKey> m_source; // The source data. 118internal LongMinMaxAggregationOperatorEnumerator(QueryOperatorEnumerator<long, TKey> source, int partitionIndex, int sign, 135QueryOperatorEnumerator<long, TKey> source = m_source;
System\Linq\Parallel\QueryOperators\Inlined\LongSumAggregationOperator.cs (5)
71protected override QueryOperatorEnumerator<long,int> CreateEnumerator<TKey>( 72int index, int count, QueryOperatorEnumerator<long, TKey> source, object sharedData, CancellationToken cancellationToken) 84private readonly QueryOperatorEnumerator<long, TKey> m_source; // The source data. 90internal LongSumAggregationOperatorEnumerator(QueryOperatorEnumerator<long, TKey> source, int partitionIndex, 108QueryOperatorEnumerator<long, TKey> source = m_source;
System\Linq\Parallel\QueryOperators\Inlined\NullableDecimalAverageAggregationOperator.cs (5)
76protected override QueryOperatorEnumerator<Pair<decimal, long>, int> CreateEnumerator<TKey>( 77int index, int count, QueryOperatorEnumerator<decimal?, TKey> source, object sharedData, CancellationToken cancellationToken) 89private QueryOperatorEnumerator<decimal?, TKey> m_source; // The source data. 95internal NullableDecimalAverageAggregationOperatorEnumerator(QueryOperatorEnumerator<decimal?, TKey> source, int partitionIndex, 114QueryOperatorEnumerator<decimal?, TKey> source = m_source;
System\Linq\Parallel\QueryOperators\Inlined\NullableDecimalMinMaxAggregationOperator.cs (5)
93protected override QueryOperatorEnumerator<decimal?, int> CreateEnumerator<TKey>( 94int index, int count, QueryOperatorEnumerator<decimal?, TKey> source, object sharedData, CancellationToken cancellationToken) 106private QueryOperatorEnumerator<decimal?, TKey> m_source; // The source data. 113internal NullableDecimalMinMaxAggregationOperatorEnumerator(QueryOperatorEnumerator<decimal?, TKey> source, int partitionIndex, int sign, 130QueryOperatorEnumerator<decimal?, TKey> source = m_source;
System\Linq\Parallel\QueryOperators\Inlined\NullableDecimalSumAggregationOperator.cs (5)
65protected override QueryOperatorEnumerator<decimal?,int> CreateEnumerator<TKey>( 66int index, int count, QueryOperatorEnumerator<decimal?, TKey> source, object sharedData, CancellationToken cancellationToken) 78private readonly QueryOperatorEnumerator<decimal?, TKey> m_source; // The source data. 84internal NullableDecimalSumAggregationOperatorEnumerator(QueryOperatorEnumerator<decimal?, TKey> source, int partitionIndex, 102QueryOperatorEnumerator<decimal?, TKey> source = m_source;
System\Linq\Parallel\QueryOperators\Inlined\NullableDoubleAverageAggregationOperator.cs (5)
76protected override QueryOperatorEnumerator<Pair<double, long>, int> CreateEnumerator<TKey>( 77int index, int count, QueryOperatorEnumerator<double?, TKey> source, object sharedData, CancellationToken cancellationToken) 89private QueryOperatorEnumerator<double?, TKey> m_source; // The source data. 95internal NullableDoubleAverageAggregationOperatorEnumerator(QueryOperatorEnumerator<double?, TKey> source, int partitionIndex, 114QueryOperatorEnumerator<double?, TKey> source = m_source;
System\Linq\Parallel\QueryOperators\Inlined\NullableDoubleMinMaxAggregationOperator.cs (5)
101protected override QueryOperatorEnumerator<double?, int> CreateEnumerator<TKey>( 102int index, int count, QueryOperatorEnumerator<double?, TKey> source, object sharedData, CancellationToken cancellationToken) 114private QueryOperatorEnumerator<double?, TKey> m_source; // The source data. 121internal NullableDoubleMinMaxAggregationOperatorEnumerator(QueryOperatorEnumerator<double?, TKey> source, int partitionIndex, int sign, 138QueryOperatorEnumerator<double?, TKey> source = m_source;
System\Linq\Parallel\QueryOperators\Inlined\NullableDoubleSumAggregationOperator.cs (5)
65protected override QueryOperatorEnumerator<double?,int> CreateEnumerator<TKey>( 66int index, int count, QueryOperatorEnumerator<double?, TKey> source, object sharedData, CancellationToken cancellationToken) 78private readonly QueryOperatorEnumerator<double?, TKey> m_source; // The source data. 84internal NullableDoubleSumAggregationOperatorEnumerator(QueryOperatorEnumerator<double?, TKey> source, int partitionIndex, 102QueryOperatorEnumerator<double?, TKey> source = m_source;
System\Linq\Parallel\QueryOperators\Inlined\NullableFloatAverageAggregationOperator.cs (5)
76protected override QueryOperatorEnumerator<Pair<double, long>,int> CreateEnumerator<TKey>( 77int index, int count, QueryOperatorEnumerator<float?, TKey> source, object sharedData, CancellationToken cancellationToken) 89private QueryOperatorEnumerator<float?, TKey> m_source; // The source data. 95internal NullableFloatAverageAggregationOperatorEnumerator(QueryOperatorEnumerator<float?, TKey> source, int partitionIndex, 114QueryOperatorEnumerator<float?, TKey> source = m_source;
System\Linq\Parallel\QueryOperators\Inlined\NullableFloatMinMaxAggregationOperator.cs (5)
101protected override QueryOperatorEnumerator<float?, int> CreateEnumerator<TKey>( 102int index, int count, QueryOperatorEnumerator<float?, TKey> source, object sharedData, CancellationToken cancellationToken) 114private QueryOperatorEnumerator<float?, TKey> m_source; // The source data. 121internal NullableFloatMinMaxAggregationOperatorEnumerator(QueryOperatorEnumerator<float?, TKey> source, int partitionIndex, int sign, 138QueryOperatorEnumerator<float?, TKey> source = m_source;
System\Linq\Parallel\QueryOperators\Inlined\NullableFloatSumAggregationOperator.cs (5)
65protected override QueryOperatorEnumerator<double?,int> CreateEnumerator<TKey>( 66int index, int count, QueryOperatorEnumerator<float?, TKey> source, object sharedData, CancellationToken cancellationToken) 78private readonly QueryOperatorEnumerator<float?, TKey> m_source; // The source data. 84internal NullableFloatSumAggregationOperatorEnumerator(QueryOperatorEnumerator<float?, TKey> source, int partitionIndex, 102QueryOperatorEnumerator<float?, TKey> source = m_source;
System\Linq\Parallel\QueryOperators\Inlined\NullableIntAverageAggregationOperator.cs (5)
76protected override QueryOperatorEnumerator<Pair<long, long>,int> CreateEnumerator<TKey>( 77int index, int count, QueryOperatorEnumerator<int?, TKey> source, object sharedData, CancellationToken cancellationToken) 89private QueryOperatorEnumerator<int?, TKey> m_source; // The source data. 95internal NullableIntAverageAggregationOperatorEnumerator(QueryOperatorEnumerator<int?, TKey> source, int partitionIndex, 114QueryOperatorEnumerator<int?, TKey> source = m_source;
System\Linq\Parallel\QueryOperators\Inlined\NullableIntMinMaxAggregationOperator.cs (5)
93protected override QueryOperatorEnumerator<int?, int> CreateEnumerator<TKey>( 94int index, int count, QueryOperatorEnumerator<int?, TKey> source, object sharedData, CancellationToken cancellationToken) 106private QueryOperatorEnumerator<int?, TKey> m_source; // The source data. 113internal NullableIntMinMaxAggregationOperatorEnumerator(QueryOperatorEnumerator<int?, TKey> source, int partitionIndex, int sign, 130QueryOperatorEnumerator<int?, TKey> source = m_source;
System\Linq\Parallel\QueryOperators\Inlined\NullableIntSumAggregationOperator.cs (5)
68protected override QueryOperatorEnumerator<int?,int> CreateEnumerator<TKey>( 69int index, int count, QueryOperatorEnumerator<int?, TKey> source, object sharedData, CancellationToken cancellationToken) 81private QueryOperatorEnumerator<int?, TKey> m_source; // The source data. 87internal NullableIntSumAggregationOperatorEnumerator(QueryOperatorEnumerator<int?, TKey> source, int partitionIndex, 105QueryOperatorEnumerator<int?, TKey> source = m_source;
System\Linq\Parallel\QueryOperators\Inlined\NullableLongAverageAggregationOperator.cs (5)
76protected override QueryOperatorEnumerator<Pair<long, long>, int> CreateEnumerator<TKey>( 77int index, int count, QueryOperatorEnumerator<long?, TKey> source, object sharedData, 90private QueryOperatorEnumerator<long?, TKey> m_source; // The source data. 96internal NullableLongAverageAggregationOperatorEnumerator(QueryOperatorEnumerator<long?, TKey> source, int partitionIndex, 115QueryOperatorEnumerator<long?, TKey> source = m_source;
System\Linq\Parallel\QueryOperators\Inlined\NullableLongMinMaxAggregationOperator.cs (5)
93protected override QueryOperatorEnumerator<long?, int> CreateEnumerator<TKey>( 94int index, int count, QueryOperatorEnumerator<long?, TKey> source, object sharedData, 107private QueryOperatorEnumerator<long?, TKey> m_source; // The source data. 114internal NullableLongMinMaxAggregationOperatorEnumerator(QueryOperatorEnumerator<long?, TKey> source, int partitionIndex, int sign, 131QueryOperatorEnumerator<long?, TKey> source = m_source;
System\Linq\Parallel\QueryOperators\Inlined\NullableLongSumAggregationOperator.cs (5)
68protected override QueryOperatorEnumerator<long?,int> CreateEnumerator<TKey>( 69int index, int count, QueryOperatorEnumerator<long?, TKey> source, object sharedData, 82private readonly QueryOperatorEnumerator<long?, TKey> m_source; // The source data. 88internal NullableLongSumAggregationOperatorEnumerator(QueryOperatorEnumerator<long?, TKey> source, int partitionIndex, 106QueryOperatorEnumerator<long?, TKey> source = m_source;
System\Linq\Parallel\QueryOperators\QueryOperatorEnumerator.cs (2)
61private QueryOperatorEnumerator<TElement, TKey> m_operatorEnumerator; 64internal QueryOperatorClassicEnumerator(QueryOperatorEnumerator<TElement, TKey> operatorEnumerator)
System\Linq\Parallel\QueryOperators\Unary\AnyAllSearchOperator.cs (2)
154private readonly QueryOperatorEnumerator<TInput, TKey> m_source; // The source data. 165internal AnyAllSearchOperatorEnumerator(QueryOperatorEnumerator<TInput, TKey> source, bool qualification,
System\Linq\Parallel\QueryOperators\Unary\ConcatQueryOperator.cs (4)
165private QueryOperatorEnumerator<TSource, TLeftKey> m_firstSource; // The first data source to enumerate. 166private QueryOperatorEnumerator<TSource, TRightKey> m_secondSource; // The second data source to enumerate. 174QueryOperatorEnumerator<TSource, TLeftKey> firstSource, 175QueryOperatorEnumerator<TSource, TRightKey> secondSource)
System\Linq\Parallel\QueryOperators\Unary\ContainsSearchOperator.cs (2)
141private readonly QueryOperatorEnumerator<TInput, TKey> m_source; // The source data. 152internal ContainsSearchOperatorEnumerator(QueryOperatorEnumerator<TInput, TKey> source, TInput searchValue,
System\Linq\Parallel\QueryOperators\Unary\DefaultIfEmptyQueryOperator.cs (2)
108private QueryOperatorEnumerator<TSource, TKey> m_source; // The data source to enumerate. 124QueryOperatorEnumerator<TSource, TKey> source, TSource defaultValue, int partitionIndex, int partitionCount,
System\Linq\Parallel\QueryOperators\Unary\DistinctQueryOperator.cs (5)
99outputStream[i] = (QueryOperatorEnumerator<TInputOutput, TKey>)(object) 126private QueryOperatorEnumerator<Pair<TInputOutput, NoKeyMemoizationRequired>, TKey> m_source; // The data source. 136QueryOperatorEnumerator<Pair<TInputOutput, NoKeyMemoizationRequired>, TKey> source, IEqualityComparer<TInputOutput> comparer, 200private QueryOperatorEnumerator<Pair<TInputOutput, NoKeyMemoizationRequired>, TKey> m_source; // The data source. 211QueryOperatorEnumerator<Pair<TInputOutput, NoKeyMemoizationRequired>, TKey> source,
System\Linq\Parallel\QueryOperators\Unary\ElementAtQueryOperator.cs (2)
172private QueryOperatorEnumerator<TSource, int> m_source; // The source data. 181internal ElementAtQueryOperatorEnumerator(QueryOperatorEnumerator<TSource, int> source,
System\Linq\Parallel\QueryOperators\Unary\FirstQueryOperator.cs (2)
125private QueryOperatorEnumerator<TSource, TKey> m_source; // The data source to enumerate. 141QueryOperatorEnumerator<TSource, TKey> source, Func<TSource, bool> predicate,
System\Linq\Parallel\QueryOperators\Unary\ForAllOperator.cs (2)
129private readonly QueryOperatorEnumerator<TInput, TKey> m_source; // The data source. 137internal ForAllEnumerator(QueryOperatorEnumerator<TInput, TKey> source, Action<TInput> elementAction, CancellationToken cancellationToken)
System\Linq\Parallel\QueryOperators\Unary\GroupByQueryOperator.cs (10)
123outputStream[i] = (QueryOperatorEnumerator<IGrouping<TGroupKey, TElement>, TKey>)(object)enumerator; 163outputStream[i] = (QueryOperatorEnumerator<IGrouping<TGroupKey, TElement>, TKey>)(object)enumerator; 231protected readonly QueryOperatorEnumerator<Pair<TSource, TGroupKey>, TOrderKey> m_source; // The data source to enumerate. 247QueryOperatorEnumerator<Pair<TSource, TGroupKey>, TOrderKey> source, 318QueryOperatorEnumerator<Pair<TSource, TGroupKey>, TOrderKey> source, 380QueryOperatorEnumerator<Pair<TSource, TGroupKey>, TOrderKey> source, 436protected readonly QueryOperatorEnumerator<Pair<TSource, TGroupKey>, TOrderKey> m_source; // The data source to enumerate. 453protected OrderedGroupByQueryOperatorEnumerator(QueryOperatorEnumerator<Pair<TSource, TGroupKey>, TOrderKey> source, 550internal OrderedGroupByIdentityQueryOperatorEnumerator(QueryOperatorEnumerator<Pair<TSource, TGroupKey>, TOrderKey> source, 624internal OrderedGroupByElementSelectorQueryOperatorEnumerator(QueryOperatorEnumerator<Pair<TSource, TGroupKey>, TOrderKey> source,
System\Linq\Parallel\QueryOperators\Unary\IndexedSelectQueryOperator.cs (2)
141private readonly QueryOperatorEnumerator<TInput, int> m_source; // The data source to enumerate. 148internal IndexedSelectQueryOperatorEnumerator(QueryOperatorEnumerator<TInput, int> source, Func<TInput, int, TOutput> selector)
System\Linq\Parallel\QueryOperators\Unary\IndexedWhereQueryOperator.cs (2)
146private readonly QueryOperatorEnumerator<TInputOutput, int> m_source; // The data source to enumerate. 154internal IndexedWhereQueryOperatorEnumerator(QueryOperatorEnumerator<TInputOutput, int> source, Func<TInputOutput, int, bool> predicate,
System\Linq\Parallel\QueryOperators\Unary\LastQueryOperator.cs (2)
121private QueryOperatorEnumerator<TSource, TKey> m_source; // The data source to enumerate. 137QueryOperatorEnumerator<TSource, TKey> source, Func<TSource, bool> predicate,
System\Linq\Parallel\QueryOperators\Unary\ReverseQueryOperator.cs (2)
112private readonly QueryOperatorEnumerator<TSource, TKey> m_source; // The data source to reverse. 121internal ReverseQueryOperatorEnumerator(QueryOperatorEnumerator<TSource, TKey> source,
System\Linq\Parallel\QueryOperators\Unary\SelectManyQueryOperator.cs (4)
239private readonly QueryOperatorEnumerator<TLeftInput, int> m_leftSource; // The left data source to enumerate. 261internal IndexedSelectManyQueryOperatorEnumerator(QueryOperatorEnumerator<TLeftInput, int> leftSource, 369private readonly QueryOperatorEnumerator<TLeftInput, TLeftKey> m_leftSource; // The left data source to enumerate. 391internal SelectManyQueryOperatorEnumerator(QueryOperatorEnumerator<TLeftInput, TLeftKey> leftSource,
System\Linq\Parallel\QueryOperators\Unary\SelectQueryOperator.cs (2)
100private readonly QueryOperatorEnumerator<TInput, TKey> m_source; // The data source to enumerate. 107internal SelectQueryOperatorEnumerator(QueryOperatorEnumerator<TInput, TKey> source, Func<TInput, TOutput> selector)
System\Linq\Parallel\QueryOperators\Unary\SingleQueryOperator.cs (2)
102private QueryOperatorEnumerator<TSource, TKey> m_source; // The data source to enumerate. 114internal SingleQueryOperatorEnumerator(QueryOperatorEnumerator<TSource, TKey> source,
System\Linq\Parallel\QueryOperators\Unary\SortQueryOperator.cs (2)
201private readonly QueryOperatorEnumerator<TInputOutput, TKey> m_source; // Data source to sort. 209internal SortQueryOperatorEnumerator(QueryOperatorEnumerator<TInputOutput, TKey> source,
System\Linq\Parallel\QueryOperators\Unary\TakeOrSkipQueryOperator.cs (2)
154private readonly QueryOperatorEnumerator<TResult, TKey> m_source; // The data source to enumerate. 172QueryOperatorEnumerator<TResult, TKey> source, bool take,
System\Linq\Parallel\QueryOperators\Unary\TakeOrSkipWhileQueryOperator.cs (2)
211private readonly QueryOperatorEnumerator<TResult, TKey> m_source; // The data source to enumerate. 233QueryOperatorEnumerator<TResult, TKey> source, Func<TResult, bool> predicate, Func<TResult, TKey, bool> indexedPredicate, bool take,
System\Linq\Parallel\QueryOperators\Unary\WhereQueryOperator.cs (2)
109private readonly QueryOperatorEnumerator<TInputOutput, TKey> m_source; // The data source to enumerate. 118internal WhereQueryOperatorEnumerator(QueryOperatorEnumerator<TInputOutput, TKey> source, Func<TInputOutput, bool> predicate,
System\Linq\Parallel\Scheduling\OrderPreservingPipeliningSpoolingTask.cs (3)
29private readonly QueryOperatorEnumerator<TOutput, TKey> m_partition; // The source partition. 58QueryOperatorEnumerator<TOutput, TKey> partition, 101var partition = m_partition;
System\Linq\Parallel\Scheduling\SpoolingTask.cs (8)
187private QueryOperatorEnumerator<TInputOutput, TIgnoreKey> m_source; 207QueryOperatorEnumerator<TInputOutput, TIgnoreKey> source, SynchronousChannel<TInputOutput> destination) 227QueryOperatorEnumerator<TInputOutput, TIgnoreKey> source = m_source; 276private QueryOperatorEnumerator<TInputOutput, TIgnoreKey> m_source; 296QueryOperatorEnumerator<TInputOutput, TIgnoreKey> source, AsynchronousChannel<TInputOutput> destination) 316QueryOperatorEnumerator<TInputOutput, TIgnoreKey> source = m_source; 367private QueryOperatorEnumerator<TInputOutput, TIgnoreKey> m_source; 383QueryOperatorEnumerator<TInputOutput, TIgnoreKey> source)
System\Linq\Parallel\Utils\ExceptionAggregator.cs (1)
69internal static IEnumerable<TElement> WrapQueryEnumerator<TElement, TIgnoreKey>(QueryOperatorEnumerator<TElement, TIgnoreKey> source,
System\Linq\Parallel\Utils\ExchangeUtilities.cs (2)
49QueryOperatorEnumerator<T, int>[] enumerators = sourceAsPartitionable.GetPartitions(partitionCount); 64QueryOperatorEnumerator<T, int> currentEnumerator = enumerators[i];
System\Linq\Parallel\Utils\Sorting.cs (2)
42private QueryOperatorEnumerator<TInputOutput, TKey> m_source; // The data source from which to pull data. 62private SortHelper(QueryOperatorEnumerator<TInputOutput, TKey> source, int partitionCount, int partitionIndex,