OrderedHashRepartitionStream()

System.Linq.Parallel.OrderedHashRepartitionStream< TInputOutput, THashKey, TOrderKey >.OrderedHashRepartitionStream ( PartitionedStream< TInputOutput, TOrderKey > inputStream, Func< TInputOutput, THashKey > hashKeySelector, IEqualityComparer< THashKey > hashKeyComparer, IEqualityComparer< TInputOutput > elementComparer, CancellationToken cancellationToken )

inlinepackage

Definition at line 8 of file OrderedHashRepartitionStream.cs.

        : base(inputStream.PartitionCount, inputStream.KeyComparer, hashKeyComparer, elementComparer)
    {
        QueryOperatorEnumerator<Pair<TInputOutput, THashKey>, TOrderKey>[] partitions = new OrderedHashRepartitionEnumerator<TInputOutput, THashKey, TOrderKey>[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);
        ListChunk<TOrderKey>[][] keyExchangeMatrix = JaggedArray<ListChunk<TOrderKey>>.Allocate(inputStream.PartitionCount, inputStream.PartitionCount);
        for (int i = 0; i < inputStream.PartitionCount; i++)
        {
            _partitions[i] = new OrderedHashRepartitionEnumerator<TInputOutput, THashKey, TOrderKey>(inputStream[i], inputStream.PartitionCount, i, hashKeySelector, this, barrier, valueExchangeMatrix, keyExchangeMatrix, cancellationToken);
        }
    }

References System.Linq.Parallel.PartitionedStream< Pair< TInputOutput, THashKey >, TOrderKey >._partitions, and System.cancellationToken.