PrestoSparkNativeTaskExecutorFactory

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total842 of 8420%34 of 340%45451681682828
getTaskSources(Iterator, PlanFragment, Session, PrestoSparkNativeTaskInputs)2360%100%66515111
doCreate(int, int, SerializedPrestoSparkTaskDescriptor, Iterator, PrestoSparkTaskInputs, CollectionAccumulator, CollectionAccumulator, Class)1790%40%33373711
PrestoSparkNativeTaskExecutorFactory(SessionPropertyManager, BlockEncodingManager, JsonCodec, JsonCodec, Codec, Codec, PrestoSparkExecutionExceptionFactory, Set, PrestoSparkBroadcastTableCacheManager, NativeExecutionProcessFactory, NativeExecutionTaskFactory, PrestoSparkShuffleInfoTranslator)710%n/a11131311
processFailure(RuntimeException, NativeExecutionProcess, boolean, Duration)510%80%55131311
processTaskInfoForErrorsOrCompletion(TaskInfo)440%40%33111111
lambda$getTaskSources$13(AtomicLong, RemoteSourceNode, BroadcastFileInfo)370%n/a114411
completeTask(boolean, CollectionAccumulator, NativeExecutionTask, Codec, PrestoSparkNativeTaskExecutorFactory.CpuTracker)360%20%22111111
createAndStartNativeExecutionProcess(Session)220%n/a117711
create(int, int, SerializedPrestoSparkTaskDescriptor, Iterator, PrestoSparkTaskInputs, CollectionAccumulator, CollectionAccumulator, Class)170%n/a113311
getBroadcastDirectoryPath(Session)160%n/a111111
isCommunicationLoss(RuntimeException)140%20%224411
tryGetTaskInfo(NativeExecutionTask)100%n/a114411
findTableWriteNode(PlanNode)100%n/a113311
lambda$getTaskSources$5(List, PlanNodeId)100%n/a111111
lambda$completeTask$2(Optional, long)100%n/a112211
lambda$getTaskSources$11(Page)80%n/a112211
lambda$null$10(Page, int)80%n/a111111
lambda$getTaskSources$4(Set, PlanNodeId)80%20%221111
close()70%20%223311
static {...}70%n/a112211
lambda$getTaskSources$7(AtomicLong, long)60%n/a111111
lambda$processTaskInfoForErrorsOrCompletion$3()60%n/a111111
lambda$doCreate$1(Session, PrestoSparkShuffleWriteDescriptor)60%n/a111111
lambda$doCreate$0(ImmutableMap.Builder, PrestoSparkAuthenticatorProvider)60%n/a111111
lambda$getTaskSources$12(String)50%n/a111111
lambda$getTaskSources$9(SerializedPage)50%n/a111111
lambda$getTaskSources$6(TaskSource)40%n/a111111
lambda$getTaskSources$8(PrestoSparkSerializedPage)30%n/a111111