本文整理了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
暂无
代码示例来源: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);
}
}
内容来源于网络,如有侵权,请联系作者删除!