WrapPartitionedStream< TKey >()

override void System.Linq.Parallel.IndexedSelectQueryOperator< TInput, TOutput >.WrapPartitionedStream< TKey > ( PartitionedStream< TInput, TKey > inputStream, IPartitionedStreamRecipient< TOutput > recipient, bool preferStriping, QuerySettings settings )

inlinepackage

Definition at line 105 of file IndexedSelectQueryOperator.cs.

    {
        int partitionCount = inputStream.PartitionCount;
        PartitionedStream<TInput, int> partitionedStream;
        if (_prematureMerge)
        {
            ListQueryResults<TInput> listQueryResults = QueryOperator<TInput>.ExecuteAndCollectResults(inputStream, partitionCount, base.Child.OutputOrdered, preferStriping, settings);
            partitionedStream = listQueryResults.GetPartitionedStream();
        }
        else
        {
            partitionedStream = (PartitionedStream<TInput, int>)(object)inputStream;
        }
        PartitionedStream<TOutput, int> partitionedStream2 = new PartitionedStream<TOutput, int>(partitionCount, Util.GetDefaultComparer<int>(), OrdinalIndexState);
        for (int i = 0; i < partitionCount; i++)
        {
            partitionedStream2[i] = new IndexedSelectQueryOperatorEnumerator(partitionedStream[i], _selector);
        }
        recipient.Receive(partitionedStream2);
    }

References System.Linq.Parallel.IndexedSelectQueryOperator< TInput, TOutput >._prematureMerge, and System.Linq.Parallel.IndexedSelectQueryOperator< TInput, TOutput >._selector.