WrapPartitionedStream< TLeftKey >()

override void System.Linq.Parallel.SelectManyQueryOperator< TLeftInput, TRightInput, TOutput >.WrapPartitionedStream< TLeftKey > ( PartitionedStream< TLeftInput, TLeftKey > inputStream, IPartitionedStreamRecipient< TOutput > recipient, bool preferStriping, QuerySettings settings )

inlinepackage

Definition at line 216 of file SelectManyQueryOperator.cs.

    {
        int partitionCount = inputStream.PartitionCount;
        if (_indexedRightChildSelector != null)
        {
            PartitionedStream<TLeftInput, int> inputStream2;
            if (_prematureMerge)
            {
                ListQueryResults<TLeftInput> listQueryResults = QueryOperator<TLeftInput>.ExecuteAndCollectResults(inputStream, partitionCount, base.OutputOrdered, preferStriping, settings);
                inputStream2 = listQueryResults.GetPartitionedStream();
            }
            else
            {
                inputStream2 = (PartitionedStream<TLeftInput, int>)(object)inputStream;
            }
            WrapPartitionedStreamIndexed(inputStream2, recipient, settings);
        }
        else if (_prematureMerge)
        {
            PartitionedStream<TLeftInput, int> partitionedStream = QueryOperator<TLeftInput>.ExecuteAndCollectResults(inputStream, partitionCount, base.OutputOrdered, preferStriping, settings).GetPartitionedStream();
            WrapPartitionedStreamNotIndexed(partitionedStream, recipient, settings);
        }
        else
        {
            WrapPartitionedStreamNotIndexed(inputStream, recipient, settings);
        }
    }

References System.Linq.Parallel.SelectManyQueryOperator< TLeftInput, TRightInput, TOutput >._indexedRightChildSelector, System.Linq.Parallel.SelectManyQueryOperator< TLeftInput, TRightInput, TOutput >._prematureMerge, and System.Linq.Parallel.SelectManyQueryOperator< TLeftInput, TRightInput, TOutput >.WrapPartitionedStreamIndexed().