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

QueryStats.getEndTime介绍

暂无

代码示例

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

@Override
public Optional<DateTime> getEndTime()
{
  return Optional.ofNullable(queryInfo.getQueryStats().getEndTime());
}

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

public void queryCompletedEvent(QueryInfo queryInfo)
{
  QueryStats queryStats = queryInfo.getQueryStats();
  eventListenerManager.queryCompleted(
      new QueryCompletedEvent(
          createQueryMetadata(queryInfo),
          createQueryStatistics(queryInfo),
          createQueryContext(queryInfo.getSession(), queryInfo.getResourceGroupId()),
          getQueryIOMetadata(queryInfo),
          createQueryFailureInfo(queryInfo.getFailureInfo(), queryInfo.getOutputStage()),
          queryInfo.getWarnings(),
          ofEpochMilli(queryStats.getCreateTime().getMillis()),
          ofEpochMilli(queryStats.getExecutionStartTime().getMillis()),
          ofEpochMilli(queryStats.getEndTime() != null ? queryStats.getEndTime().getMillis() : 0)));
  logQueryTimeline(queryInfo);
}

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

@Override
public Optional<DateTime> getEndTime()
{
  return Optional.ofNullable(getQueryInfo().getQueryStats().getEndTime());
}

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

QueryStats queryStats = queryInfo.getQueryStats();
DateTime queryStartTime = queryStats.getCreateTime();
DateTime queryEndTime = queryStats.getEndTime();

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

toTimeStamp(queryStats.getExecutionStartTime()),
toTimeStamp(queryStats.getLastHeartbeat()),
toTimeStamp(queryStats.getEndTime()));

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

assertNotNull(queryStats.getEndTime());
assertNull(queryStats.getEndTime());

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

assertEquals(actual.getExecutionStartTime(), new DateTime(2, UTC));
assertEquals(actual.getLastHeartbeat(), new DateTime(3, UTC));
assertEquals(actual.getEndTime(), new DateTime(4, UTC));

代码示例来源：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

queryStats.getExecutionStartTime(),
queryStats.getLastHeartbeat(),
queryStats.getEndTime(),
queryStats.getElapsedTime(),
queryStats.getQueuedTime(),

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

/**
 * Remove completed queries after a waiting period
 */
private void removeExpiredQueries()
{
  DateTime timeHorizon = DateTime.now().minus(maxQueryAge.toMillis());
  // we're willing to keep queries beyond timeHorizon as long as we have fewer than maxQueryHistory
  while (expirationQueue.size() > maxQueryHistory) {
    QueryInfo queryInfo = expirationQueue.peek().getQueryInfo();
    // expirationQueue is FIFO based on query end time. Stop when we see the
    // first query that's too young to expire
    if (queryInfo.getQueryStats().getEndTime().isAfter(timeHorizon)) {
      return;
    }
    // only expire them if they are older than maxQueryAge. We need to keep them
    // around for a while in case clients come back asking for status
    QueryId queryId = queryInfo.getQueryId();
    log.debug("Remove query %s", queryId);
    queries.remove(queryId);
    expirationQueue.remove();
  }
}

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

QueryStats queryStats = queryInfo.getQueryStats();
DateTime queryStartTime = queryStats.getCreateTime();
DateTime queryEndTime = queryStats.getEndTime();

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

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

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

assertEquals(actual.getExecutionStartTime(), new DateTime(2, UTC));
assertEquals(actual.getLastHeartbeat(), new DateTime(3, UTC));
assertEquals(actual.getEndTime(), new DateTime(4, UTC));

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

assertNull(queryStats.getExecutionStartTime());
assertNull(queryStats.getFinishingTime());
assertNull(queryStats.getEndTime());
assertNull(queryStats.getExecutionStartTime());
assertNull(queryStats.getFinishingTime());
assertNull(queryStats.getEndTime());
assertNull(queryStats.getExecutionStartTime());
assertNull(queryStats.getFinishingTime());
assertNull(queryStats.getEndTime());
assertNotNull(queryStats.getExecutionStartTime());
assertNull(queryStats.getFinishingTime());
assertNull(queryStats.getEndTime());
assertNotNull(queryStats.getExecutionStartTime());
assertNull(queryStats.getFinishingTime());
assertNull(queryStats.getEndTime());
assertNotNull(queryStats.getExecutionStartTime());
assertNotNull(queryStats.getFinishingTime());
assertNotNull(queryStats.getEndTime());

代码示例来源：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();
}

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

long executionWallMillis = info.getQueryStats().getEndTime().getMillis() - info.getQueryStats().getCreateTime().getMillis();
executionTime.add(executionWallMillis, MILLISECONDS);
if (executionWallMillis > 0) {

代码示例来源：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());
}