| LocalExchange(PartitioningProviderManager, Session, int, int, PartitioningHandle, List, List, Optional, DataSize) |  | 0% | | 0% | 8 | 8 | 30 | 30 | 1 | 1 |
| createPartitionFunction(PartitioningProviderManager, Session, PartitioningHandle, int, List, boolean) | | 0% | | 0% | 5 | 5 | 19 | 19 | 1 | 1 |
| computeBufferCount(PartitioningHandle, int, List) | | 0% | | 0% | 7 | 7 | 16 | 16 | 1 | 1 |
| createSink(LocalExchange.LocalExchangeSinkFactory) | | 0% | | 0% | 2 | 2 | 9 | 9 | 1 | 1 |
| checkAllSourcesFinished() | | 0% | | 0% | 2 | 2 | 11 | 11 | 1 | 1 |
| checkAllSinksComplete() | | 0% | | 0% | 4 | 4 | 7 | 7 | 1 | 1 |
| getNextSource() | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| lambda$new$6(Iterator, DataSize, int) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| createSinkFactory() | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
| sinkFinished(LocalExchangeSink) | | 0% | | n/a | 1 | 1 | 6 | 6 | 1 | 1 |
| sinkFactoryClosed(LocalExchange.LocalExchangeSinkFactory) | | 0% | | n/a | 1 | 1 | 6 | 6 | 1 | 1 |
| lambda$new$7(List, PartitioningProviderManager, Session, PartitioningHandle, int, List, Optional, List) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| noMoreSinkFactories() | | 0% | | n/a | 1 | 1 | 6 | 6 | 1 | 1 |
| checkNotHoldsLock(Object) | | 0% | | 0% | 2 | 2 | 2 | 2 | 1 | 1 |
| getSinkFactory(LocalExchange.LocalExchangeSinkFactoryId) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$new$5(List) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$new$4(List) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$new$3(List) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getSource(int) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$new$2(LocalExchangeSource) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$new$0() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getBufferCount() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| getBufferedBytes() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$new$1(LocalExchangeSource) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |