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

QueryStateMachine.waitForStateChange介绍

暂无

代码示例

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

@Override
public Duration waitForStateChange(QueryState currentState, Duration maxWait)
    throws InterruptedException
{
  return stateMachine.waitForStateChange(currentState, maxWait);
}

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

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

@Test
public void testFinished()
    throws InterruptedException
{
  QueryStateMachine stateMachine = createQueryStateMachine();
  assertTrue(stateMachine.transitionToFinishing());
  stateMachine.waitForStateChange(FINISHING, new Duration(2, TimeUnit.SECONDS));
  assertFinalState(stateMachine, FINISHED);
}

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

@Test
public void testBasicStateChanges()
    throws InterruptedException
{
  QueryStateMachine stateMachine = createQueryStateMachine();
  assertState(stateMachine, QUEUED);
  assertTrue(stateMachine.transitionToPlanning());
  assertState(stateMachine, PLANNING);
  assertTrue(stateMachine.transitionToStarting());
  assertState(stateMachine, STARTING);
  assertTrue(stateMachine.transitionToRunning());
  assertState(stateMachine, RUNNING);
  assertTrue(stateMachine.transitionToFinishing());
  stateMachine.waitForStateChange(FINISHING, new Duration(2, TimeUnit.SECONDS));
  assertState(stateMachine, FINISHED);
}

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

@Test
public void testRunning()
    throws InterruptedException
{
  QueryStateMachine stateMachine = createQueryStateMachine();
  assertTrue(stateMachine.transitionToRunning());
  assertState(stateMachine, RUNNING);
  assertFalse(stateMachine.transitionToPlanning());
  assertState(stateMachine, RUNNING);
  assertFalse(stateMachine.transitionToStarting());
  assertState(stateMachine, RUNNING);
  assertFalse(stateMachine.transitionToRunning());
  assertState(stateMachine, RUNNING);
  assertTrue(stateMachine.transitionToFinishing());
  stateMachine.waitForStateChange(FINISHING, new Duration(2, TimeUnit.SECONDS));
  assertState(stateMachine, FINISHED);
  stateMachine = createQueryStateMachine();
  stateMachine.transitionToRunning();
  assertTrue(stateMachine.transitionToFailed(FAILED_CAUSE));
  assertState(stateMachine, FAILED);
}

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

@Test
public void testStarting()
    throws InterruptedException
{
  QueryStateMachine stateMachine = createQueryStateMachine();
  assertTrue(stateMachine.transitionToStarting());
  assertState(stateMachine, STARTING);
  assertFalse(stateMachine.transitionToPlanning());
  assertState(stateMachine, STARTING);
  assertFalse(stateMachine.transitionToStarting());
  assertState(stateMachine, STARTING);
  assertTrue(stateMachine.transitionToRunning());
  assertState(stateMachine, RUNNING);
  stateMachine = createQueryStateMachine();
  stateMachine.transitionToStarting();
  assertTrue(stateMachine.transitionToFinishing());
  stateMachine.waitForStateChange(FINISHING, new Duration(2, TimeUnit.SECONDS));
  assertState(stateMachine, FINISHED);
  stateMachine = createQueryStateMachine();
  stateMachine.transitionToStarting();
  assertTrue(stateMachine.transitionToFailed(FAILED_CAUSE));
  assertState(stateMachine, FAILED);
}

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

@Test
public void testQueued()
    throws InterruptedException
{
  QueryStateMachine stateMachine = createQueryStateMachine();
  assertState(stateMachine, QUEUED);
  assertTrue(stateMachine.transitionToPlanning());
  assertState(stateMachine, PLANNING);
  stateMachine = createQueryStateMachine();
  assertTrue(stateMachine.transitionToStarting());
  assertState(stateMachine, STARTING);
  stateMachine = createQueryStateMachine();
  assertTrue(stateMachine.transitionToRunning());
  assertState(stateMachine, RUNNING);
  stateMachine = createQueryStateMachine();
  assertTrue(stateMachine.transitionToFinishing());
  stateMachine.waitForStateChange(FINISHING, new Duration(2, TimeUnit.SECONDS));
  assertState(stateMachine, FINISHED);
  stateMachine = createQueryStateMachine();
  assertTrue(stateMachine.transitionToFailed(FAILED_CAUSE));
  assertState(stateMachine, FAILED);
}

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

@Test
public void testPlanning()
    throws InterruptedException
{
  QueryStateMachine stateMachine = createQueryStateMachine();
  assertTrue(stateMachine.transitionToPlanning());
  assertState(stateMachine, PLANNING);
  assertFalse(stateMachine.transitionToPlanning());
  assertState(stateMachine, PLANNING);
  assertTrue(stateMachine.transitionToStarting());
  assertState(stateMachine, STARTING);
  stateMachine = createQueryStateMachine();
  stateMachine.transitionToPlanning();
  assertTrue(stateMachine.transitionToRunning());
  assertState(stateMachine, RUNNING);
  stateMachine = createQueryStateMachine();
  stateMachine.transitionToPlanning();
  assertTrue(stateMachine.transitionToFinishing());
  stateMachine.waitForStateChange(FINISHING, new Duration(2, TimeUnit.SECONDS));
  assertState(stateMachine, FINISHED);
  stateMachine = createQueryStateMachine();
  stateMachine.transitionToPlanning();
  assertTrue(stateMachine.transitionToFailed(FAILED_CAUSE));
  assertState(stateMachine, FAILED);
}