PipelineContext

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total1,028 of 1,0280%48 of 480%62622162163838
getPipelineStats()3560%140%88797911
PipelineContext(int, TaskContext, Executor, ScheduledExecutorService, MemoryTrackingContext, boolean, boolean, boolean)1530%n/a11333311
driverFinished(DriverContext)1450%60%44262611
addDriverContext(long, Lifespan, Optional)340%40%335511
splitsAdded(int, long)320%80%556611
getInputDataSize()260%20%226611
getInputPositions()260%20%226611
getOutputDataSize()260%20%226611
getOutputPositions()260%20%226611
getPipelineStatus(Iterator, int, int, long, boolean)210%20%224411
start()160%n/a115511
getPipelineStatus()150%n/a111111
freeSpill(long)140%20%223311
getActivePartitionedSplitsWeight()130%20%223311
lambda$getPipelineStats$1(Map.Entry)130%n/a111111
lambda$driverFinished$0(OperatorStats, Integer, OperatorStats)120%20%221111
acceptChildren(QueryContextVisitor, Object)110%n/a113311
getPhysicalWrittenDataSize()70%n/a113311
addDriverContext()60%n/a111111
failed(Throwable)50%n/a112211
reserveSpill(long)50%n/a111111
moreMemoryAvailable()50%n/a112211
accept(QueryContextVisitor, Object)50%n/a111111
lambda$acceptChildren$3(QueryContextVisitor, Object, DriverContext)50%n/a111111
getTaskId()40%n/a111111
getSession()40%n/a111111
isDone()40%n/a111111
localSystemMemoryContext()40%n/a111111
isPerOperatorCpuTimerEnabled()40%n/a111111
isCpuTimerEnabled()40%n/a111111
isPerOperatorAllocationTrackingEnabled()40%n/a111111
isAllocationTrackingEnabled()40%n/a111111
lambda$getPipelineStats$2(Integer)40%n/a111111
getTaskContext()30%n/a111111
getPipelineId()30%n/a111111
isInputPipeline()30%n/a111111
isOutputPipeline()30%n/a111111
getPipelineMemoryContext()30%n/a111111