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

QueryContext.finished介绍

[英]The finished query persisted.
[中]完成的查询仍然存在。

代码示例

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

private boolean cancelQuery(@NonNull QueryHandle queryHandle) throws LensException {
 QueryContext ctx =  allQueries.get(queryHandle);
 if (ctx == null) {
  log.info("Could not cancel query {} as it has been purged already", queryHandle);
  return false;
 }
 synchronized (ctx) {
  updateStatus(queryHandle);
  if (ctx.finished()) {
   log.info("Could not cancel query {} as it has finished execution already", queryHandle);
   return false;
  }
  if (ctx.isLaunching()) {
   boolean launchCancelled = ctx.getQueryLauncher().cancel(true);
   log.info("query launch cancellation success : {}", launchCancelled);
  }
  if (ctx.launched() || ctx.running()) {
   if (!ctx.getSelectedDriver().cancelQuery(queryHandle)) {
    log.info("Could not cancel query {}", queryHandle);
    return false;
   }
  }
  log.info("Query {} cancelled successfully", queryHandle);
  setCancelledStatus(ctx, "Query is cancelled");
  return true;
 }
}

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

/**
 * Sets the failed status.
 *
 * @param ctx       the ctx
 * @param statusMsg the status msg
 * @param e    the LensException
 * @throws LensException the lens exception
 */
void setFailedStatus(QueryContext ctx, String statusMsg, Exception e) throws LensException {
 QueryStatus before = ctx.getStatus();
 ctx.setStatus(new QueryStatus(0.0f, null, FAILING, statusMsg, false, null, LensUtil.getCauseMessage(e),
  e instanceof LensException ? ((LensException)e).buildLensErrorTO(this.errorCollection) : null));
 handleRetries(ctx);
 if (ctx.finished()) {
  updateFinishedQuery(ctx, before);
 }
 fireStatusChangeEvent(ctx, ctx.getStatus(), before);
}

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

while (!queryCtx.finished() && System.currentTimeMillis() < timeOutTime) {
 queryCtx = getUpdatedQueryContext(sessionHandle, handle);
 try {
if (queryCtx.finished() && queryCtx.getStatus().isResultSetAvailable()) {
 resultSet = getResultset(handle);
 result.setResultMetadata(resultSet.getMetadata().toQueryResultSetMetadata());
result.setStatus(queryCtx.getStatus());
if (!queryCtx.finished()) {

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

synchronized (ctx) {
 QueryStatus before = ctx.getStatus();
 if (!ctx.queued() && !ctx.finished()) {
  if (updateDriverStatus) {
   try {

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

assertFalse(ctx3.finished()); //Formatting is deferred so query will take time to finish
try {
 queryService.fetchResultSet(lensSessionId, handle3, 0, 100);