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

QueryManager.cancelQuery介绍

[英]Attempts to fail the query due to a user cancellation. If the query is already in a final state, the call is ignored. If the query does not exist, the call is ignored.
[中]由于用户取消，试图使查询失败。如果查询已经处于最终状态，则调用将被忽略。如果查询不存在，则忽略该调用。

代码示例

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

@DELETE
@Path("{queryId}")
public void cancelQuery(@PathParam("queryId") QueryId queryId)
{
  requireNonNull(queryId, "queryId is null");
  queryManager.cancelQuery(queryId);
}

代码示例来源：origin: io.prestosql/presto-main

@DELETE
@Path("{queryId}")
public void cancelQuery(@PathParam("queryId") QueryId queryId)
{
  requireNonNull(queryId, "queryId is null");
  queryManager.cancelQuery(queryId);
}

代码示例来源：origin: io.prestosql/presto-main

public void cancel()
{
  // if submission is not finished, send cancel after it is finished
  if (submissionFuture.isDone()) {
    submissionFuture.addListener(() -> queryManager.cancelQuery(queryId), resultsProcessorExecutor);
  }
  else {
    queryManager.cancelQuery(queryId);
  }
  dispose();
}

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

public void cancel()
{
  // if submission is not finished, send cancel after it is finished
  if (submissionFuture.isDone()) {
    submissionFuture.addListener(() -> queryManager.cancelQuery(queryId), resultsProcessorExecutor);
  }
  else {
    queryManager.cancelQuery(queryId);
  }
  dispose();
}

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

@Override
public Plan createPlan(Session session, String sql, WarningCollector warningCollector)
{
  QueryId queryId = executeWithQueryId(session, sql).getQueryId();
  Plan queryPlan = getQueryPlan(queryId);
  coordinator.getQueryManager().cancelQuery(queryId);
  return queryPlan;
}

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

private void cancelAllQueries()
{
  QueryManager queryManager = coordinator.getQueryManager();
  for (BasicQueryInfo queryInfo : queryManager.getQueries()) {
    if (!queryInfo.getState().isDone()) {
      queryManager.cancelQuery(queryInfo.getQueryId());
    }
  }
}

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

public static void cancelQuery(DistributedQueryRunner queryRunner, QueryId queryId)
{
  queryRunner.getCoordinator().getQueryManager().cancelQuery(queryId);
}

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

@Test
public void testMetadataIsClearedAfterQueryCanceled()
    throws Exception
{
  QueryManager queryManager = queryRunner.getCoordinator().getQueryManager();
  QueryId queryId = queryManager.createQueryId();
  queryManager.createQuery(
      queryId,
      new TestingSessionContext(TEST_SESSION),
      "SELECT * FROM lineitem")
      .get();
  // wait until query starts running
  while (true) {
    QueryInfo queryInfo = queryManager.getFullQueryInfo(queryId);
    if (queryInfo.getState().isDone()) {
      assertEquals(queryInfo.getState(), FAILED);
      throw queryInfo.getFailureInfo().toException();
    }
    if (queryInfo.getState() == RUNNING) {
      break;
    }
    Thread.sleep(100);
  }
  // cancel query
  queryManager.cancelQuery(queryId);
  assertEquals(metadataManager.getCatalogsByQueryId().size(), 0);
}