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

QueryContext.setStatusSkippingTransitionTest介绍

暂无

代码示例

代码示例来源：origin: apache/lens

private void launchQuery(final QueryContext query) throws LensException {
  checkEstimatedQueriesState(query);
  query.getSelectedDriver().getQueryHook().preLaunch(query);
  QueryStatus oldStatus = query.getStatus();
  // If driver supports async updates.
  if (query.getSelectedDriver().getStatusUpdateMethod() == StatusUpdateMethod.PUSH) {
   query.registerStatusUpdateListener(asyncStatusUpdater);
  }
  QueryStatus newStatus = new QueryStatus(query.getStatus().getProgress(), null,
   QueryStatus.Status.LAUNCHED, "Query is launched on driver", false, null, null, null);
  query.validateTransition(newStatus);
  // Check if we need to pass session's effective resources to selected driver
  addSessionResourcesToDriver(query);
  query.getSelectedDriver().executeAsync(query);
  query.setStatusSkippingTransitionTest(newStatus);
  query.clearTransientStateAfterLaunch();
  log.info("Added to launched queries. QueryId:{}", query.getQueryHandleString());
  fireStatusChangeEvent(query, newStatus, oldStatus);
 }
}

代码示例来源：origin: org.apache.lens/lens-server-api

public QueryContext toQueryContext(Configuration conf, Collection<LensDriver> drivers) {
 if (null == selectedDriver && null != driverName) {
  selectedDriver = getDriverFromName(drivers);
 }
 QueryContext qctx =
  new QueryContext(userQuery, submitter, this.conf, conf, drivers, selectedDriver, submissionTime,
   false);
 qctx.setQueryHandle(QueryHandle.fromString(handle));
 qctx.setLaunchTime(this.startTime);
 qctx.setEndTime(getEndTime());
 qctx.setStatusSkippingTransitionTest(new QueryStatus(0.0, null, QueryStatus.Status.valueOf(getStatus()),
  null, getResult() != null, null, getErrorMessage() == null ? "" : getErrorMessage(), null));
 qctx.getDriverStatus().setDriverStartTime(getDriverStartTime());
 qctx.getDriverStatus().setDriverFinishTime(getDriverEndTime());
 qctx.setResultSetPath(getResult());
 qctx.setQueryName(getQueryName());
 if (null != driverQuery){
  qctx.setSelectedDriverQuery(driverQuery);
 }
 if (getPriority() != null) {
  qctx.setPriority(Priority.valueOf(getPriority()));
 }
 qctx.setFailedAttempts(getFailedAttempts());
 return qctx;
}

代码示例来源：origin: apache/lens

public QueryContext toQueryContext(Configuration conf, Collection<LensDriver> drivers) {
 if (null == selectedDriver && null != driverName) {
  selectedDriver = getDriverFromName(drivers);
 }
 QueryContext qctx =
  new QueryContext(userQuery, submitter, this.conf, conf, drivers, selectedDriver, submissionTime,
   false);
 qctx.setQueryHandle(QueryHandle.fromString(handle));
 qctx.setLaunchTime(this.startTime);
 qctx.setEndTime(getEndTime());
 qctx.setStatusSkippingTransitionTest(new QueryStatus(0.0, null, QueryStatus.Status.valueOf(getStatus()),
  null, getResult() != null, null, getErrorMessage() == null ? "" : getErrorMessage(), null));
 qctx.getDriverStatus().setDriverStartTime(getDriverStartTime());
 qctx.getDriverStatus().setDriverFinishTime(getDriverEndTime());
 qctx.setResultSetPath(getResult());
 qctx.setQueryName(getQueryName());
 if (null != driverQuery){
  qctx.setSelectedDriverQuery(driverQuery);
 }
 if (getPriority() != null) {
  qctx.setPriority(Priority.valueOf(getPriority()));
 }
 qctx.setFailedAttempts(getFailedAttempts());
 return qctx;
}