lambda$run$9(CancellationToken, Throwable) | | 0% | | 0% | 11 | 11 | 39 | 39 | 1 | 1 |
lambda$run$5(CancellationToken, FeedResponse) | | 0% | | 0% | 6 | 6 | 21 | 21 | 1 | 1 |
run(CancellationToken) | | 0% | | n/a | 1 | 1 | 13 | 13 | 1 | 1 |
lambda$run$1(CancellationToken, PartitionProcessorImpl) | | 0% | | 0% | 3 | 3 | 10 | 10 | 1 | 1 |
PartitionProcessorImpl(ChangeFeedObserver, ChangeFeedContextClient, ProcessorSettings, PartitionCheckpointer, Lease) | | 0% | | n/a | 1 | 1 | 10 | 10 | 1 | 1 |
dispatchChanges(FeedResponse, ChangeFeedState) | | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
getPkRangeFeedRangeFromStartState() | | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
lambda$run$6() | | 0% | | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
lambda$run$7(CancellationToken, Instant) | | 0% | | 0% | 3 | 3 | 2 | 2 | 1 | 1 |
lambda$run$0(CancellationToken, Instant) | | 0% | | 0% | 3 | 3 | 2 | 2 | 1 | 1 |
lambda$run$10(CancellationToken) | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
lambda$run$4(String, CancellationToken, Void) | | 0% | | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
lambda$run$11(Throwable) | | 0% | | 0% | 2 | 2 | 3 | 3 | 1 | 1 |
lambda$run$2(PartitionProcessorImpl) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
lambda$run$12(SignalType) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
lambda$run$3(Throwable) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
static {...} | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getResultException() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$run$8(Long) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |