WrapPartitionedStream< TKey >() [2/2]

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

inlinepackage

Definition at line 124 of file FirstQueryOperator.cs.

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

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