com.facebook.presto.execution.QueryStats.getElapsedTime()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(4.0k)|赞(0)|评价(0)|浏览(64)

本文整理了Java中com.facebook.presto.execution.QueryStats.getElapsedTime方法的一些代码示例,展示了QueryStats.getElapsedTime的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。QueryStats.getElapsedTime方法的具体详情如下:
包路径:com.facebook.presto.execution.QueryStats
类名称:QueryStats
方法名:getElapsedTime

QueryStats.getElapsedTime介绍

暂无

代码示例

代码示例来源:origin: prestodb/presto

assertEquals(actual.getEndTime(), new DateTime(4, UTC));
assertEquals(actual.getElapsedTime(), new Duration(6, NANOSECONDS));
assertEquals(actual.getQueuedTime(), new Duration(5, NANOSECONDS));
assertEquals(actual.getExecutionTime(), new Duration(41, NANOSECONDS));

代码示例来源:origin: prestodb/presto

assertNotNull(queryStats.getElapsedTime());
assertNotNull(queryStats.getQueuedTime());
assertNotNull(queryStats.getResourceWaitingTime());

代码示例来源:origin: prestodb/presto

assertEquals(queryStats.getElapsedTime().toMillis(), 1050);
assertEquals(queryStats.getQueuedTime().toMillis(), 50);
assertEquals(queryStats.getResourceWaitingTime().toMillis(), 100);

代码示例来源:origin: prestodb/presto

public BasicQueryStats(QueryStats queryStats)
{
  this(queryStats.getCreateTime(),
      queryStats.getEndTime(),
      queryStats.getQueuedTime(),
      queryStats.getElapsedTime(),
      queryStats.getExecutionTime(),
      queryStats.getTotalDrivers(),
      queryStats.getQueuedDrivers(),
      queryStats.getRunningDrivers(),
      queryStats.getCompletedDrivers(),
      queryStats.getRawInputDataSize(),
      queryStats.getRawInputPositions(),
      queryStats.getCumulativeUserMemory(),
      queryStats.getUserMemoryReservation(),
      queryStats.getTotalMemoryReservation(),
      queryStats.getPeakUserMemoryReservation(),
      queryStats.getTotalCpuTime(),
      queryStats.getTotalScheduledTime(),
      queryStats.isFullyBlocked(),
      queryStats.getBlockedReasons(),
      queryStats.getProgressPercentage());
}

代码示例来源: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.getLastHeartbeat(),
queryStats.getEndTime(),
queryStats.getElapsedTime(),
queryStats.getQueuedTime(),
queryStats.getResourceWaitingTime(),

代码示例来源:origin: uk.co.nichesolutions.presto/presto-main

assertEquals(actual.getEndTime(), new DateTime(4, UTC));
assertEquals(actual.getElapsedTime(), new Duration(5, NANOSECONDS));
assertEquals(actual.getQueuedTime(), new Duration(6, NANOSECONDS));
assertEquals(actual.getAnalysisTime(), new Duration(7, NANOSECONDS));

代码示例来源:origin: uk.co.nichesolutions.presto/presto-main

public BasicQueryInfo(QueryInfo queryInfo)
{
  this(queryInfo.getQueryId(),
      queryInfo.getSession(),
      queryInfo.getState(),
      queryInfo.getErrorType(),
      queryInfo.getErrorCode(),
      queryInfo.isScheduled(),
      queryInfo.getQueryStats().isFullyBlocked(),
      queryInfo.getQueryStats().getBlockedReasons(),
      queryInfo.getSelf(),
      queryInfo.getQuery(),
      queryInfo.getQueryStats().getElapsedTime(),
      queryInfo.getQueryStats().getEndTime(),
      queryInfo.getQueryStats().getCreateTime(),
      queryInfo.getQueryStats().getRunningDrivers(),
      queryInfo.getQueryStats().getQueuedDrivers(),
      queryInfo.getQueryStats().getCompletedDrivers(),
      queryInfo.getQueryStats().getTotalDrivers());
}

相关文章

微信公众号

最新文章

更多