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

QueryStateMachine.<init>介绍

暂无

代码示例

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

QueryStateMachine queryStateMachine = new QueryStateMachine(
    query,
    session,

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

/**
 * Create a QueryStateMachine that is already in a failed state.
 */
public static QueryStateMachine failed(QueryId queryId, String query, Session session, URI self, TransactionManager transactionManager, Executor executor, Throwable throwable)
{
  QueryStateMachine queryStateMachine = new QueryStateMachine(queryId, query, session, self, false, transactionManager, executor);
  queryStateMachine.transitionToFailed(throwable);
  return queryStateMachine;
}

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

/**
 * Created QueryStateMachines must be transitioned to terminal states to clean up resources.
 */
public static QueryStateMachine begin(QueryId queryId, String query, Session session, URI self, boolean transactionControl, TransactionManager transactionManager, Executor executor)
{
  session.getTransactionId().ifPresent(transactionControl ? transactionManager::trySetActive : transactionManager::checkAndSetActive);
  Session querySession;
  boolean autoCommit = !session.getTransactionId().isPresent() && !transactionControl;
  if (autoCommit) {
    // TODO: make autocommit isolation level a session parameter
    TransactionId transactionId = transactionManager.beginTransaction(true);
    querySession = session.withTransactionId(transactionId);
  }
  else {
    querySession = session;
  }
  QueryStateMachine queryStateMachine = new QueryStateMachine(queryId, query, querySession, self, autoCommit, transactionManager, executor);
  queryStateMachine.addStateChangeListener(newState -> log.debug("Query %s is %s", queryId, newState));
  queryStateMachine.addStateChangeListener(newState -> {
    if (newState.isDone()) {
      session.getTransactionId().ifPresent(transactionManager::trySetInactive);
    }
  });
  return queryStateMachine;
}