WrapPartitionedStream< TKey >() [2/2]

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

inlinepackage

Definition at line 128 of file LastQueryOperator.cs.

    {
        if (_prematureMergeNeeded)
        {
            PartitionedStream<TSource, int> partitionedStream = QueryOperator<TSource>.ExecuteAndCollectResults(inputStream, inputStream.PartitionCount, base.Child.OutputOrdered, preferStriping, settings).GetPartitionedStream();
            WrapHelper(partitionedStream, recipient, settings);
        }
        else
        {
            WrapHelper(inputStream, recipient, settings);
        }
    }

References System.Linq.Parallel.LastQueryOperator< TSource >._prematureMergeNeeded.