| startPartitionPump(PartitionOwnership, Checkpoint) |  | 0% | | 0% | 9 | 9 | 51 | 51 | 1 | 1 |
| processEvents(PartitionContext, PartitionProcessor, EventHubConsumerAsyncClient, List) | | 0% | | 0% | 6 | 6 | 28 | 28 | 1 | 1 |
| processEvent(PartitionContext, PartitionProcessor, EventHubConsumerAsyncClient, EventContext) | | 0% | | 0% | 5 | 5 | 25 | 25 | 1 | 1 |
| verifyPartitionConnection(PartitionOwnership) | | 0% | | 0% | 3 | 3 | 21 | 21 | 1 | 1 |
| endProcessTracingSpan(Context, Signal) | | 0% | | 0% | 6 | 6 | 17 | 17 | 1 | 1 |
| PartitionPumpManager(CheckpointStore, Supplier, EventHubClientBuilder, boolean, TracerProvider, Map, int, Duration, boolean) | | 0% | | 0% | 2 | 2 | 17 | 17 | 1 | 1 |
| startProcessTracingSpan(EventData, String, String) | | 0% | | 0% | 5 | 5 | 12 | 12 | 1 | 1 |
| handleError(PartitionOwnership, PartitionPump, PartitionProcessor, Throwable, PartitionContext) | | 0% | | 0% | 3 | 3 | 14 | 14 | 1 | 1 |
| cleanup(PartitionOwnership, PartitionPump) | | 0% | | n/a | 1 | 1 | 7 | 7 | 1 | 1 |
| lambda$startPartitionPump$1(PartitionContext, PartitionEvent) | | 0% | | 0% | 2 | 2 | 7 | 7 | 1 | 1 |
| lambda$stopAllPartitionPumps$0(String, PartitionPump) | | 0% | | n/a | 1 | 1 | 7 | 7 | 1 | 1 |
| lambda$startPartitionPump$4(PartitionProcessor, PartitionContext, PartitionOwnership, PartitionPump) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
| lambda$processEvents$5(LastEnqueuedEventProperties[], PartitionEvent) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| lambda$startPartitionPump$3(PartitionOwnership, PartitionPump, PartitionProcessor, PartitionContext, Throwable) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$startPartitionPump$2(PartitionContext, PartitionProcessor, EventHubConsumerAsyncClient, List) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| stopAllPartitionPumps() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
| getPartitionPumps() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |