testNativeExecutionTask() |  | 0% |  | 0% | 3 | 3 | 33 | 33 | 1 | 1 |
testResultFetcherExceedingBufferLimit() |  | 0% |  | 0% | 4 | 4 | 26 | 26 | 1 | 1 |
testInfoFetcherWithRetry() |  | 0% | | n/a | 1 | 1 | 21 | 21 | 1 | 1 |
testResultFetcherMultipleNonEmptyResults() |  | 0% |  | 0% | 2 | 2 | 16 | 16 | 1 | 1 |
testResultFetcherTransportErrorRecovery() |  | 0% |  | 0% | 2 | 2 | 18 | 18 | 1 | 1 |
testResultFetcherPrestoException() |  | 0% |  | 0% | 2 | 2 | 16 | 16 | 1 | 1 |
testInfoFetcherUnexpectedResponse() |  | 0% |  | 0% | 3 | 3 | 13 | 13 | 1 | 1 |
testGetServerInfoWithRetry() |  | 0% | | n/a | 1 | 1 | 13 | 13 | 1 | 1 |
testResultFetcher() |  | 0% |  | 0% | 2 | 2 | 16 | 16 | 1 | 1 |
testResultFetcherTransportErrorFail() |  | 0% |  | 0% | 2 | 2 | 12 | 12 | 1 | 1 |
testGetServerInfo() |  | 0% | | n/a | 1 | 1 | 12 | 12 | 1 | 1 |
testInfoFetcherWaitOnSignal() |  | 0% |  | 0% | 2 | 2 | 14 | 14 | 1 | 1 |
testUpdateTaskWithRetries() |  | 0% | | n/a | 1 | 1 | 11 | 11 | 1 | 1 |
testGetServerInfoWithRetryTimeout() |  | 0% | | n/a | 1 | 1 | 8 | 8 | 1 | 1 |
testResultFetcherWaitOnSignal() |  | 0% |  | 0% | 2 | 2 | 15 | 15 | 1 | 1 |
testUpdateTask() |  | 0% | | n/a | 1 | 1 | 16 | 16 | 1 | 1 |
testInfoFetcher() |  | 0% | | n/a | 1 | 1 | 12 | 12 | 1 | 1 |
testResultGet() |  | 0% | | n/a | 1 | 1 | 12 | 12 | 1 | 1 |
createNativeExecutionProcess(Duration, TestPrestoSparkHttpClient.TestingResponseManager) |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
testUpdateTaskUnexpectedResponse() |  | 0% | | n/a | 1 | 1 | 7 | 7 | 1 | 1 |
testGetTaskInfo() |  | 0% | | n/a | 1 | 1 | 9 | 9 | 1 | 1 |
fetchResults(HttpNativeExecutionTaskResultFetcher, int) |  | 0% |  | 0% | 4 | 4 | 6 | 6 | 1 | 1 |
static {...} |  | 0% | | n/a | 1 | 1 | 10 | 10 | 1 | 1 |
testResultAbort() |  | 0% | | n/a | 1 | 1 | 9 | 9 | 1 | 1 |
createWorkerClient(TaskId, TestPrestoSparkHttpClient.TestingHttpClient) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
createTaskInfoFetcher(TaskId, TestPrestoSparkHttpClient.TestingResponseManager, Duration, Object) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
lambda$testUpdateTaskUnexpectedResponse$0(PrestoSparkHttpTaskClient) |  | 0% | | n/a | 1 | 1 | 7 | 7 | 1 | 1 |
createSerializedPage(int) |  | 0% | | n/a | 1 | 1 | 5 | 5 | 1 | 1 |
testResultAcknowledge() |  | 0% | | n/a | 1 | 1 | 4 | 4 | 1 | 1 |
createWorkerClient(TaskId) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
isTaskDone(Optional) |  | 0% |  | 0% | 3 | 3 | 1 | 1 | 1 | 1 |
createTaskInfoFetcher(TaskId, TestPrestoSparkHttpClient.TestingResponseManager) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
afterClass() |  | 0% |  | 0% | 2 | 2 | 4 | 4 | 1 | 1 |
createTaskInfoFetcher(TaskId, TestPrestoSparkHttpClient.TestingResponseManager, Object) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
createResultFetcher(PrestoSparkHttpTaskClient, Object) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
createResultFetcher(PrestoSparkHttpTaskClient) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
beforeClass() |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
lambda$testGetServerInfoWithRetryTimeout$1(SettableFuture) |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
TestPrestoSparkHttpClient() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |