本文整理了Java中com.facebook.presto.execution.QueryStats.getExecutionStartTime
方法的一些代码示例,展示了QueryStats.getExecutionStartTime
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。QueryStats.getExecutionStartTime
方法的具体详情如下:
包路径:com.facebook.presto.execution.QueryStats
类名称: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();
}
内容来源于网络,如有侵权,请联系作者删除!