WrapPartitionedStream< TKey >() [2/2]

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

inlinepackage

Definition at line 85 of file IndexedWhereQueryOperator.cs.

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

References System.Linq.Parallel.IndexedWhereQueryOperator< TInputOutput >._predicate, System.Linq.Parallel.IndexedWhereQueryOperator< TInputOutput >._prematureMerge, System.Linq.Parallel.QuerySettings.CancellationState, and System.Linq.Parallel.CancellationState.MergedCancellationToken.