lambda$loadBalance$6(Tuple2) | | 0% | | 0% | 7 | 7 | 49 | 49 | 1 | 1 |
loadBalance() | | 0% | | 0% | 3 | 3 | 26 | 26 | 1 | 1 |
claimOwnership(Map, Map, String) | | 0% | | n/a | 1 | 1 | 21 | 21 | 1 | 1 |
PartitionBasedLoadBalancer(CheckpointStore, EventHubAsyncClient, String, String, String, String, long, PartitionPumpManager, Consumer, LoadBalancingStrategy) | | 0% | | n/a | 1 | 1 | 17 | 17 | 1 | 1 |
findPartitionToSteal(Map) | | 0% | | n/a | 1 | 1 | 9 | 9 | 1 | 1 |
isLoadBalanced(int, int, Map) | | 0% | | 0% | 6 | 6 | 9 | 9 | 1 | 1 |
lambda$claimOwnership$24(Throwable) | | 0% | | 0% | 2 | 2 | 6 | 6 | 1 | 1 |
renewOwnership(Map) | | 0% | | n/a | 1 | 1 | 8 | 8 | 1 | 1 |
createPartitionOwnershipRequest(Map, String) | | 0% | | 0% | 2 | 2 | 9 | 9 | 1 | 1 |
lambda$format$12(Map.Entry) | | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
lambda$isValid$13(PartitionOwnership) | | 0% | | 0% | 8 | 8 | 7 | 7 | 1 | 1 |
lambda$loadBalance$2(Throwable) | | 0% | | n/a | 1 | 1 | 6 | 6 | 1 | 1 |
shouldOwnMorePartitions(int, Map) | | 0% | | 0% | 3 | 3 | 4 | 4 | 1 | 1 |
lambda$removeInactivePartitionOwnerships$15(Map.Entry) | | 0% | | 0% | 3 | 3 | 3 | 3 | 1 | 1 |
lambda$claimOwnership$16(Map, String) | | 0% | | 0% | 3 | 3 | 2 | 2 | 1 | 1 |
lambda$renewOwnership$7(Map, String) | | 0% | | 0% | 3 | 3 | 2 | 2 | 1 | 1 |
closeClient() | | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
lambda$claimOwnership$19(PartitionOwnership, Throwable) | | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
lambda$renewOwnership$9(Throwable) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
lambda$claimOwnership$21(List) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
removeInactivePartitionOwnerships(Map) | | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
lambda$claimOwnership$22(Tuple2, PartitionOwnership) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
lambda$loadBalance$0() | | 0% | | 0% | 3 | 3 | 1 | 1 | 1 | 1 |
format(Map) | | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
lambda$claimOwnership$18(PartitionOwnership) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
lambda$claimOwnership$25() | | 0% | | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
lambda$claimOwnership$23(Tuple2) | | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
lambda$loadBalance$5(Map) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
lambda$loadBalance$4(Map, String) | | 0% | | 0% | 2 | 2 | 1 | 1 | 1 | 1 |
isValid(Map) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
loadBalance(Tuple2) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$claimOwnership$17(Map, String) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$findPartitionToSteal$14(Map.Entry) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$renewOwnership$10() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$renewOwnership$8(Map, String) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$loadBalance$3() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
static {...} | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$claimOwnership$20(Checkpoint) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$format$11(PartitionOwnership) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$loadBalance$1(Void) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |