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

QueryManager.getAllQueryInfo介绍

暂无

代码示例

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

@GET
public List<BasicQueryInfo> getAllQueryInfo()
{
  return extractBasicQueryInfo(queryManager.getAllQueryInfo());
}

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

List<QueryInfo> queryInfos = queryRunner.getCoordinator().getQueryManager().getAllQueryInfo();
for (QueryInfo info : queryInfos) {
  assertEquals(info.getState(), FINISHED);

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

private void testNoLeak(@Language("SQL") String query)
    throws Exception
{
  Map<String, String> properties = ImmutableMap.<String, String>builder()
      .put("task.verbose-stats", "true")
      .put("task.operator-pre-allocated-memory", "0B")
      .build();
  try (DistributedQueryRunner queryRunner = createQueryRunner(TINY_SESSION, properties)) {
    executor.submit(() -> queryRunner.execute(query)).get();
    List<QueryInfo> queryInfos = queryRunner.getCoordinator().getQueryManager().getAllQueryInfo();
    for (QueryInfo info : queryInfos) {
      assertEquals(info.getState(), FINISHED);
    }
    // Make sure we didn't leak any memory on the workers
    for (TestingPrestoServer worker : queryRunner.getServers()) {
      MemoryPool reserved = worker.getLocalMemoryManager().getPool(RESERVED_POOL);
      assertEquals(reserved.getMaxBytes(), reserved.getFreeBytes());
      MemoryPool general = worker.getLocalMemoryManager().getPool(GENERAL_POOL);
      assertEquals(general.getMaxBytes(), general.getFreeBytes());
      MemoryPool system = worker.getLocalMemoryManager().getPool(SYSTEM_POOL);
      assertEquals(system.getMaxBytes(), system.getFreeBytes());
    }
  }
}

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

for (QueryInfo info : queryRunner.getCoordinator().getQueryManager().getAllQueryInfo()) {
  if (info.getState().isDone()) {
    assertEquals(info.getErrorCode().getCode(), CLUSTER_OUT_OF_MEMORY.toErrorCode().getCode());

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

List<QueryInfo> currentQueryInfos = queryRunner.getCoordinator().getQueryManager().getAllQueryInfo();
for (QueryInfo info : currentQueryInfos) {
  assertFalse(info.getState().isDone());
  currentQueryInfos = queryRunner.getCoordinator().getQueryManager().getAllQueryInfo();
  for (QueryInfo info : currentQueryInfos) {
    assertFalse(info.getState().isDone());
List<QueryInfo> queryInfos = queryRunner.getCoordinator().getQueryManager().getAllQueryInfo();
for (QueryInfo info : queryInfos) {
  assertEquals(info.getState(), FINISHED);

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