本文整理了Java中com.facebook.presto.execution.QueryStats.getBlockedDrivers
方法的一些代码示例,展示了QueryStats.getBlockedDrivers
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。QueryStats.getBlockedDrivers
方法的具体详情如下:
包路径:com.facebook.presto.execution.QueryStats
类名称:QueryStats
方法名:getBlockedDrivers
暂无
代码示例来源:origin: prestodb/presto
assertEquals(actual.getQueuedDrivers(), 13);
assertEquals(actual.getRunningDrivers(), 15);
assertEquals(actual.getBlockedDrivers(), 30);
assertEquals(actual.getCompletedDrivers(), 16);
代码示例来源:origin: prestodb/presto
private static StatementStats toStatementStats(QueryInfo queryInfo)
{
QueryStats queryStats = queryInfo.getQueryStats();
StageInfo outputStage = queryInfo.getOutputStage().orElse(null);
return StatementStats.builder()
.setState(queryInfo.getState().toString())
.setQueued(queryInfo.getState() == QueryState.QUEUED)
.setScheduled(queryInfo.isScheduled())
.setNodes(globalUniqueNodes(outputStage).size())
.setTotalSplits(queryStats.getTotalDrivers())
.setQueuedSplits(queryStats.getQueuedDrivers())
.setRunningSplits(queryStats.getRunningDrivers() + queryStats.getBlockedDrivers())
.setCompletedSplits(queryStats.getCompletedDrivers())
.setCpuTimeMillis(queryStats.getTotalCpuTime().toMillis())
.setWallTimeMillis(queryStats.getTotalScheduledTime().toMillis())
.setQueuedTimeMillis(queryStats.getQueuedTime().toMillis())
.setElapsedTimeMillis(queryStats.getElapsedTime().toMillis())
.setProcessedRows(queryStats.getRawInputPositions())
.setProcessedBytes(queryStats.getRawInputDataSize().toBytes())
.setPeakMemoryBytes(queryStats.getPeakUserMemoryReservation().toBytes())
.setSpilledBytes(queryStats.getSpilledDataSize().toBytes())
.setRootStage(toStageStats(outputStage))
.build();
}
代码示例来源:origin: prestodb/presto
queryStats.getQueuedDrivers(),
queryStats.getRunningDrivers(),
queryStats.getBlockedDrivers(),
queryStats.getCompletedDrivers(),
queryStats.getCumulativeUserMemory(),
内容来源于网络,如有侵权,请联系作者删除!