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

QueryStateMachine.getQueryId介绍

暂无

代码示例

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

@Override
public QueryId getQueryId()
{
  return stateMachine.getQueryId();
}

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

@Override
public QueryId getQueryId()
{
  return stateMachine.getQueryId();
}

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

public void abort()
{
  try (SetThreadName ignored = new SetThreadName("Query-%s", queryStateMachine.getQueryId())) {
    stages.values().forEach(SqlStageExecution::abort);
  }
}

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

public void cancelStage(StageId stageId)
{
  try (SetThreadName ignored = new SetThreadName("Query-%s", queryStateMachine.getQueryId())) {
    SqlStageExecution sqlStageExecution = stages.get(stageId);
    SqlStageExecution stage = requireNonNull(sqlStageExecution, () -> format("Stage %s does not exist", stageId));
    stage.cancel();
  }
}

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

@Override
public void cancelStage(StageId stageId)
{
  requireNonNull(stageId, "stageId is null");
  try (SetThreadName ignored = new SetThreadName("Query-%s", stateMachine.getQueryId())) {
    SqlQueryScheduler scheduler = queryScheduler.get();
    if (scheduler != null) {
      scheduler.cancelStage(stageId);
    }
  }
}

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

@Override
public void addStateChangeListener(StateChangeListener<QueryState> stateChangeListener)
{
  try (SetThreadName ignored = new SetThreadName("Query-%s", stateMachine.getQueryId())) {
    stateMachine.addStateChangeListener(stateChangeListener);
  }
}

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

@Override
public QueryInfo getQueryInfo()
{
  try (SetThreadName ignored = new SetThreadName("Query-%s", stateMachine.getQueryId())) {
    // acquire reference to scheduler before checking finalQueryInfo, because
    // state change listener sets finalQueryInfo and then clears scheduler when
    // the query finishes.
    SqlQueryScheduler scheduler = queryScheduler.get();
    return stateMachine.getFinalQueryInfo().orElseGet(() -> buildQueryInfo(scheduler));
  }
}

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

metadata,
    warningCollector);
queryStateMachine.addStateChangeListener(newState -> QUERY_STATE_LOG.debug("Query %s is %s", queryStateMachine.getQueryId(), newState));

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

StageId stageId = new StageId(queryStateMachine.getQueryId(), nextStageId.getAndIncrement());
SqlStageExecution stage = createSqlStageExecution(
    stageId,

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

private void schedule()
  try (SetThreadName ignored = new SetThreadName("Query-%s", queryStateMachine.getQueryId())) {
    Set<StageId> completedStages = new HashSet<>();
    ExecutionSchedule executionSchedule = executionPolicy.createExecutionSchedule(stages.values());

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

private void startExecution()
  try (SetThreadName ignored = new SetThreadName("Query-%s", stateMachine.getQueryId())) {
    try {

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

private static void assertState(QueryStateMachine stateMachine, QueryState expectedState, Exception expectedException)
  assertEquals(stateMachine.getQueryId(), TEST_SESSION.getQueryId());
  assertEqualSessionsWithoutTransactionId(stateMachine.getSession(), TEST_SESSION);
  assertSame(stateMachine.getMemoryPool(), MEMORY_POOL);

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

@Override
public QueryId getQueryId()
{
  return stateMachine.getQueryId();
}

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

@Override
public QueryId getQueryId()
{
  return stateMachine.getQueryId();
}

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

public void abort()
{
  try (SetThreadName ignored = new SetThreadName("Query-%s", queryStateMachine.getQueryId())) {
    stages.values().stream()
        .forEach(SqlStageExecution::abort);
  }
}

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

public void cancelStage(StageId stageId)
{
  try (SetThreadName ignored = new SetThreadName("Query-%s", queryStateMachine.getQueryId())) {
    SqlStageExecution sqlStageExecution = stages.get(stageId);
    SqlStageExecution stage = requireNonNull(sqlStageExecution, () -> format("Stage %s does not exist", stageId));
    stage.cancel();
  }
}

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

@Override
public void cancelStage(StageId stageId)
{
  requireNonNull(stageId, "stageId is null");
  try (SetThreadName ignored = new SetThreadName("Query-%s", stateMachine.getQueryId())) {
    SqlQueryScheduler scheduler = queryScheduler.get();
    if (scheduler != null) {
      scheduler.cancelStage(stageId);
    }
  }
}

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

@Override
public QueryInfo getQueryInfo()
{
  try (SetThreadName ignored = new SetThreadName("Query-%s", stateMachine.getQueryId())) {
    // acquire reference to scheduler before checking finalQueryInfo, because
    // state change listener sets finalQueryInfo and then clears scheduler when
    // the query finishes.
    SqlQueryScheduler scheduler = queryScheduler.get();
    QueryInfo finalQueryInfo = this.finalQueryInfo.get();
    if (finalQueryInfo != null) {
      return finalQueryInfo;
    }
    return buildQueryInfo(scheduler);
  }
}

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

@Override
public void addStateChangeListener(StateChangeListener<QueryState> stateChangeListener)
{
  try (SetThreadName ignored = new SetThreadName("Query-%s", stateMachine.getQueryId())) {
    stateMachine.addStateChangeListener(stateChangeListener);
  }
}

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

@Override
public Duration waitForStateChange(QueryState currentState, Duration maxWait)
    throws InterruptedException
{
  try (SetThreadName ignored = new SetThreadName("Query-%s", stateMachine.getQueryId())) {
    return stateMachine.waitForStateChange(currentState, maxWait);
  }
}