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

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

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

QueryStats.getExecutionStartTime介绍

暂无

代码示例

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

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

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

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

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

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

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

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

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

public static void assertExpectedQueryStats(QueryStats actual)
  assertEquals(actual.getExecutionStartTime(), new DateTime(2, UTC));
  assertEquals(actual.getLastHeartbeat(), new DateTime(3, UTC));
  assertEquals(actual.getEndTime(), new DateTime(4, UTC));

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

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

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

queryStats.getPeakMemoryReservation().toBytes(),
queryStats.getCreateTime(),
queryStats.getExecutionStartTime(),
queryStats.getEndTime(),
queryStats.getQueuedTime(),

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

public static void assertExpectedQueryStats(QueryStats actual)
  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.getQueuedTime());
assertNull(queryStats.getTotalPlanningTime());
assertNull(queryStats.getExecutionStartTime());
assertNull(queryStats.getFinishingTime());
assertNull(queryStats.getEndTime());
assertNotNull(queryStats.getQueuedTime());
assertNull(queryStats.getTotalPlanningTime());
assertNull(queryStats.getExecutionStartTime());
assertNull(queryStats.getFinishingTime());
assertNull(queryStats.getEndTime());
assertNotNull(queryStats.getQueuedTime());
assertNotNull(queryStats.getTotalPlanningTime());
assertNull(queryStats.getExecutionStartTime());
assertNull(queryStats.getFinishingTime());
assertNull(queryStats.getEndTime());
assertNotNull(queryStats.getQueuedTime());
assertNotNull(queryStats.getTotalPlanningTime());
assertNotNull(queryStats.getExecutionStartTime());
assertNull(queryStats.getFinishingTime());
assertNull(queryStats.getEndTime());
assertNotNull(queryStats.getQueuedTime());
assertNotNull(queryStats.getTotalPlanningTime());
assertNotNull(queryStats.getExecutionStartTime());
assertNull(queryStats.getFinishingTime());
assertNull(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();
}

相关文章

微信公众号

最新文章

更多