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

QueryStats.getQueuedTime介绍

暂无

代码示例

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

private void assertAllTimeSpentInQueueing(QueryState expectedState, Consumer<QueryStateMachine> stateTransition)
{
  TestingTicker ticker = new TestingTicker();
  QueryStateMachine stateMachine = createQueryStateMachineWithTicker(ticker);
  ticker.increment(7, MILLISECONDS);
  stateTransition.accept(stateMachine);
  assertEquals(stateMachine.getQueryState(), expectedState);
  QueryStats queryStats = stateMachine.getQueryInfo(Optional.empty()).getQueryStats();
  assertEquals(queryStats.getQueuedTime(), new Duration(7, MILLISECONDS));
  assertEquals(queryStats.getResourceWaitingTime(), new Duration(0, MILLISECONDS));
  assertEquals(queryStats.getTotalPlanningTime(), new Duration(0, MILLISECONDS));
  assertEquals(queryStats.getExecutionTime(), new Duration(0, MILLISECONDS));
  assertEquals(queryStats.getFinishingTime(), new Duration(0, MILLISECONDS));
}

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

private QueryStatistics createQueryStatistics(QueryInfo queryInfo)
{
  ImmutableList.Builder<String> operatorSummaries = ImmutableList.builder();
  for (OperatorStats summary : queryInfo.getQueryStats().getOperatorSummaries()) {
    operatorSummaries.add(operatorStatsCodec.toJson(summary));
  }
  QueryStats queryStats = queryInfo.getQueryStats();
  return new QueryStatistics(
      ofMillis(queryStats.getTotalCpuTime().toMillis()),
      ofMillis(queryStats.getTotalScheduledTime().toMillis()),
      ofMillis(queryStats.getQueuedTime().toMillis()),
      Optional.of(ofMillis(queryStats.getAnalysisTime().toMillis())),
      Optional.of(ofMillis(queryStats.getDistributedPlanningTime().toMillis())),
      queryStats.getPeakUserMemoryReservation().toBytes(),
      queryStats.getPeakTotalMemoryReservation().toBytes(),
      queryStats.getPeakTaskTotalMemory().toBytes(),
      queryStats.getRawInputDataSize().toBytes(),
      queryStats.getRawInputPositions(),
      queryStats.getOutputDataSize().toBytes(),
      queryStats.getOutputPositions(),
      queryStats.getLogicalWrittenDataSize().toBytes(),
      queryStats.getWrittenPositions(),
      queryStats.getCumulativeUserMemory(),
      queryStats.getStageGcStatistics(),
      queryStats.getCompletedDrivers(),
      queryInfo.isCompleteInfo(),
      getCpuDistributions(queryInfo),
      operatorSummaries.build());
}

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

queryInfo.getResourceGroupId().map(QuerySystemTable::resourceGroupIdToBlock).orElse(null),
toMillis(queryStats.getQueuedTime()),
toMillis(queryStats.getAnalysisTime()),
toMillis(queryStats.getDistributedPlanningTime()),

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

assertEquals(actual.getQueuedTime(), new Duration(5, NANOSECONDS));
assertEquals(actual.getExecutionTime(), new Duration(41, NANOSECONDS));
assertEquals(actual.getAnalysisTime(), new Duration(7, NANOSECONDS));

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

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

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

assertEquals(queryStats.getQueuedTime().toMillis(), 50);
assertEquals(queryStats.getResourceWaitingTime().toMillis(), 100);
assertEquals(queryStats.getTotalPlanningTime().toMillis(), 200);

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

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

consumedInputRows.update(info.getQueryStats().getRawInputPositions());
executionTime.add(info.getQueryStats().getExecutionTime());
queuedTime.add(info.getQueryStats().getQueuedTime());

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

queryStats.getExecutionStartTime(),
queryStats.getEndTime(),
queryStats.getQueuedTime(),
queryStats.getAnalysisTime(),
queryStats.getDistributedPlanningTime(),

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

assertEquals(actual.getQueuedTime(), new Duration(6, NANOSECONDS));
assertEquals(actual.getAnalysisTime(), new Duration(7, NANOSECONDS));
assertEquals(actual.getDistributedPlanningTime(), new Duration(8, NANOSECONDS));

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

assertNull(queryStats.getQueuedTime());
assertNull(queryStats.getTotalPlanningTime());
assertNull(queryStats.getExecutionStartTime());
assertNotNull(queryStats.getQueuedTime());
assertNull(queryStats.getTotalPlanningTime());
assertNull(queryStats.getExecutionStartTime());
assertNotNull(queryStats.getQueuedTime());
assertNotNull(queryStats.getTotalPlanningTime());
assertNull(queryStats.getExecutionStartTime());
assertNotNull(queryStats.getQueuedTime());
assertNotNull(queryStats.getTotalPlanningTime());
assertNotNull(queryStats.getExecutionStartTime());
assertNotNull(queryStats.getQueuedTime());
assertNotNull(queryStats.getTotalPlanningTime());
assertNotNull(queryStats.getExecutionStartTime());
assertNotNull(queryStats.getQueuedTime());
assertNotNull(queryStats.getTotalPlanningTime());
assertNotNull(queryStats.getExecutionStartTime());

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

@Override
public RecordCursor cursor(ConnectorTransactionHandle transactionHandle, ConnectorSession session, TupleDomain<Integer> constraint)
{
  Builder table = InMemoryRecordSet.builder(QUERY_TABLE);
  for (QueryInfo queryInfo : queryManager.getAllQueryInfo()) {
    QueryStats queryStats = queryInfo.getQueryStats();
    table.addRow(
        nodeId,
        queryInfo.getQueryId().toString(),
        queryInfo.getState().toString(),
        queryInfo.getSession().getUser(),
        queryInfo.getSession().getSource().orElse(null),
        queryInfo.getQuery(),
        toMillis(queryStats.getQueuedTime()),
        toMillis(queryStats.getAnalysisTime()),
        toMillis(queryStats.getDistributedPlanningTime()),
        toTimeStamp(queryStats.getCreateTime()),
        toTimeStamp(queryStats.getExecutionStartTime()),
        toTimeStamp(queryStats.getLastHeartbeat()),
        toTimeStamp(queryStats.getEndTime()));
  }
  return table.build().cursor();
}