UnorderedHashRepartitionStream()

System.Linq.Parallel.UnorderedHashRepartitionStream< TInputOutput, THashKey, TIgnoreKey >.UnorderedHashRepartitionStream ( PartitionedStream< TInputOutput, TIgnoreKey > inputStream, Func< TInputOutput, THashKey > keySelector, IEqualityComparer< THashKey > keyComparer, IEqualityComparer< TInputOutput > elementComparer, CancellationToken cancellationToken )

inlinepackage

Definition at line 8 of file UnorderedHashRepartitionStream.cs.

        : base(inputStream.PartitionCount, (IComparer<int>)Util.GetDefaultComparer<int>(), keyComparer, elementComparer)
    {
        QueryOperatorEnumerator<Pair<TInputOutput, THashKey>, int>[] partitions = new HashRepartitionEnumerator<TInputOutput, THashKey, TIgnoreKey>[inputStream.PartitionCount];
        _partitions = partitions;
        CountdownEvent barrier = new CountdownEvent(inputStream.PartitionCount);
        ListChunk<Pair<TInputOutput, THashKey>>[][] valueExchangeMatrix = JaggedArray<ListChunk<Pair<TInputOutput, THashKey>>>.Allocate(inputStream.PartitionCount, inputStream.PartitionCount);
        for (int i = 0; i < inputStream.PartitionCount; i++)
        {
            _partitions[i] = new HashRepartitionEnumerator<TInputOutput, THashKey, TIgnoreKey>(inputStream[i], inputStream.PartitionCount, i, keySelector, this, barrier, valueExchangeMatrix, cancellationToken);
        }
    }

References System.cancellationToken, and System.Linq.keySelector.