org.apache.lens.server.api.query.QueryContext.validateTransition()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(1.8k)|赞(0)|评价(0)|浏览(62)

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

QueryContext.validateTransition介绍

暂无

代码示例

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

public synchronized void setStatus(final QueryStatus newStatus) throws LensException {
 validateTransition(newStatus);
 log.info("Updating status of {} from {} to {}", getQueryHandle(), this.status, newStatus);
 this.status = newStatus;
}

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

public synchronized void setStatus(final QueryStatus newStatus) throws LensException {
 validateTransition(newStatus);
 log.info("Updating status of {} from {} to {}", getQueryHandle(), this.status, newStatus);
 this.status = newStatus;
}

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

相关文章

微信公众号

最新文章

更多