QueryStateMachine

ElementMissed InstructionsCov.Missed BranchesCov.MissedCxtyMissedLinesMissedMethods
Total2,397 of 2,3970%104 of 1040%175175632632123123
QueryStateMachine(String, Optional, Session, URI, ResourceGroupId, Optional, TransactionManager, Executor, Ticker, Metadata, WarningCollector)2700%n/a11484811
getQueryInfo(Optional)2110%120%77444411
getBasicQueryInfo(Optional)1380%n/a11474711
pruneQueryStats(QueryStats)1310%n/a11656511
pruneExpiredQueryInfo(QueryInfo, VersionedMemoryPoolId)920%n/a11444411
pruneFinishedQueryInfo(QueryInfo, Set)900%n/a11434311
transitionToFailed(Throwable, Predicate)880%40%33141411
attachSerializedCommitOutput(Input, List)550%60%44161611
pruneQueryInfoFinished()550%40%33121211
transitionToFinishing()500%60%44121211
updateMemoryUsage(long, long, long, long, long)410%n/a118811
addSerializedCommitOutputToOutput(ConnectorCommitHandle)410%20%22111111
transitionToCanceled()390%20%227711
beginWithTicker(String, Optional, Session, URI, ResourceGroupId, Optional, boolean, TransactionManager, AccessControl, Executor, Ticker, Metadata, WarningCollector)380%40%336611
addSessionFunction(SqlFunctionId, SqlInvokedFunction)340%40%335511
removeSessionFunction(SqlFunctionId, boolean)320%40%336611
pruneQueryInfoExpired()320%40%337711
addSerializedCommitOutputToInputs(List)290%20%226611
removePreparedStatement(String)290%20%225511
lambda$beginWithTicker$0(QueryStateMachine, TransactionManager, QueryState)270%20%224411
pruneStatsFromStageInfo(StageInfo)260%n/a11101011
lambda$pruneStatsFromStageInfo$26(PlanFragment)260%n/a11111111
getQueryStats(Optional, List)210%n/a118811
lambda$pruneInputHistograms$22(Input)200%n/a117711
processConnectorCommitHandle(Object)190%40%336611
cleanupQueryQuietly()170%n/a115511
pruneHistogramsFromStatsAndCosts(StatsAndCosts)170%n/a116611
lambda$getQueryInfo$3(StageInfo)170%n/a111111
updateQueryInfo(Optional)160%20%224411
lambda$pruneExpiredQueryInfo$27(StageInfo)160%n/a118811
lambda$transitionToCanceled$17(TransactionInfo)160%20%224411
lambda$transitionToFailed$15(TransactionInfo)160%20%224411
begin(String, Optional, Session, URI, ResourceGroupId, Optional, boolean, TransactionManager, AccessControl, Executor, Metadata, WarningCollector)150%n/a112211
addPreparedStatement(String, String)150%n/a114411
setStartedTransactionId(TransactionId)140%20%223311
clearTransactionId()140%20%223311
lambda$pruneHistogramsFromStatsAndCosts$25(Map.Entry)140%n/a115511
addQueryInfoStateChangeListener(StateMachine.StateChangeListener)130%n/a114411
lambda$addQueryInfoStateChangeListener$18(AtomicBoolean, StateMachine.StateChangeListener, Optional)130%40%333311
incrementCurrentRunningTaskCount()120%n/a113311
transitionToFinished()120%n/a114411
getFailureInfo()120%20%223311
addSetSessionProperties(String, String)110%n/a112211
addSetRole(String, SelectedRole)110%n/a112211
pruneStageExecutionInfo(StageExecutionInfo)110%n/a115511
setInputs(List)100%n/a113311
setPlanIdNodeMap(Map)100%n/a113311
setScalarFunctions(Set)100%n/a113311
setAggregateFunctions(Set)100%n/a113311
setWindowFunctions(Set)100%n/a113311
lambda$null$21(TableStatistics)100%n/a114411
lambda$transitionToFailed$14(QueryState)100%40%331111
lambda$transitionToFinishing$12(QueryState)100%40%331111
setPlanStatsAndCosts(StatsAndCosts)90%n/a113311
setPlanCanonicalInfo(List)90%n/a113311
setOutput(Optional)90%n/a113311
transitionToQueued()90%n/a112211
transitionToWaitingForResources()90%n/a112211
transitionToDispatching()90%n/a112211
transitionToPlanning()90%n/a112211
transitionToStarting()90%n/a112211
transitionToRunning()90%n/a112211
lambda$transitionToRunning$11(QueryState)90%20%221111
lambda$transitionToStarting$10(QueryState)90%20%221111
lambda$transitionToPlanning$9(QueryState)90%20%221111
lambda$transitionToDispatching$8(QueryState)90%20%221111
lambda$transitionToWaitingForResources$7(QueryState)90%20%221111
lambda$transitionToQueued$6(QueryState)90%20%221111
lambda$getQueryInfo$5(TaskInfo)90%20%221111
addResetSessionProperties(String)80%n/a112211
pruneInputHistograms(Set)80%n/a112211
lambda$pruneQueryInfoFinished$19(StatsAndCosts)80%n/a113311
setMemoryPool(VersionedMemoryPoolId)70%n/a112211
setSetCatalog(String)70%n/a112211
setSetSchema(String)70%n/a112211
lambda$transitionToCanceled$16(QueryState)70%20%221111
lambda$transitionToFinished$13(QueryState)70%20%221111
setColumns(List, List)60%n/a112211
updateOutputLocations(Map, boolean)60%n/a112211
isDone()60%n/a111111
lambda$null$24(VariableStatsEstimate)60%n/a113311
lambda$null$20(ColumnStatistics)60%n/a113311
lambda$updateMemoryUsage$2(long)60%n/a111111
lambda$updateMemoryUsage$1(long)60%n/a111111
getMemoryPool()50%n/a111111
addOutputInfoListener(Consumer)50%n/a112211
setUpdateInfo(UpdateInfo)50%n/a112211
setExpandedQuery(Optional)50%n/a112211
getQueryState()50%n/a111111
transitionToFailed(Throwable)50%n/a111111
addStateChangeListener(StateMachine.StateChangeListener)50%n/a112211
getStateChange(QueryState)50%n/a111111
getFinalQueryInfo()50%n/a111111
getPeakUserMemoryInBytes()40%n/a111111
getPeakTotalMemoryInBytes()40%n/a111111
getPeakTaskTotalMemory()40%n/a111111
getPeakTaskUserMemory()40%n/a111111
getPeakNodeTotalMemory()40%n/a111111
getCurrentRunningTaskCount()40%n/a111111
decrementCurrentRunningTaskCount()40%n/a111111
getPeakRunningTaskCount()40%n/a111111
beginSemanticAnalyzing()40%n/a112211
beginColumnAccessPermissionChecking()40%n/a112211
endColumnAccessPermissionChecking()40%n/a112211
recordHeartbeat()40%n/a112211
beginAnalysis()40%n/a112211
endAnalysis()40%n/a112211
getCreateTimeInMillis()40%n/a111111
getExecutionStartTimeInMillis()40%n/a111111
getLastHeartbeatInMillis()40%n/a111111
getEndTimeInMillis()40%n/a111111
lambda$pruneHistogramsFromStatsAndCosts$23(Map.Entry)40%n/a111111
lambda$getQueryInfo$4(StageExecutionInfo)40%n/a111111
static {...}40%n/a111111
getQueryId()30%n/a111111
getSession()30%n/a111111
getWarningCollector()30%n/a111111
getSetSessionProperties()30%n/a111111
getResetSessionProperties()30%n/a111111
getAddedPreparedStatements()30%n/a111111
getDeallocatedPreparedStatements()30%n/a111111
getAddedSessionFunctions()30%n/a111111
getRemovedSessionFunctions()30%n/a111111