sendNextRequest() |  | 0% |  | 0% | 12 | 12 | 37 | 37 | 1 | 1 |
TaskInfoFetcher(Consumer, TaskInfo, HttpClient, Duration, Duration, Codec, Codec, Duration, boolean, Executor, ScheduledExecutorService, ScheduledExecutorService, RemoteTaskStats, boolean, boolean, Session, MetadataManager, QueryManager, HandleResolver, ConnectorTypeSerdeManager, Protocol) |  | 0% | | n/a | 1 | 1 | 28 | 28 | 1 | 1 |
sendMetadataUpdates(MetadataUpdates) |  | 0% |  | 0% | 4 | 4 | 15 | 15 | 1 | 1 |
failed(Throwable) |  | 0% |  | 0% | 2 | 2 | 11 | 11 | 1 | 1 |
success(TaskInfo) |  | 0% | | n/a | 1 | 1 | 9 | 9 | 1 | 1 |
lambda$scheduleUpdate$1() |  | 0% |  | 0% | 4 | 4 | 11 | 11 | 1 | 1 |
updateTaskInfo(TaskInfo) |  | 0% |  | 0% | 3 | 3 | 5 | 5 | 1 | 1 |
stop() |  | 0% |  | 0% | 3 | 3 | 7 | 7 | 1 | 1 |
lambda$updateTaskInfo$2(TaskInfo, TaskInfo) |  | 0% |  | 0% | 3 | 3 | 5 | 5 | 1 | 1 |
fatal(Throwable) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
scheduleMetadataUpdates(MetadataUpdates) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
addFinalTaskInfoListener(StateMachine.StateChangeListener) |  | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
lambda$addFinalTaskInfoListener$0(AtomicBoolean, StateMachine.StateChangeListener, Optional) |  | 0% |  | 0% | 3 | 3 | 3 | 3 | 1 | 1 |
scheduleUpdate() |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
start() |  | 0% |  | 0% | 2 | 2 | 5 | 5 | 1 | 1 |
updateStats(long) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getTaskInfo() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
isDone(TaskInfo) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$scheduleMetadataUpdates$3(MetadataUpdates) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |