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

QueryContext.setDriverStatus介绍

暂无

代码示例

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

public void setDriverStatus(DriverQueryStatus.DriverQueryState state) {
 setDriverStatus(state, null);
}

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

public void setDriverStatus(DriverQueryStatus.DriverQueryState state) {
 setDriverStatus(state, null);
}

代码示例来源：origin: org.apache.lens/lens-driver-es

@Override
public boolean cancelQuery(QueryHandle handle) throws LensException {
 try {
  boolean cancelled = resultSetMap.get(handle).cancel(true);
  if (cancelled) {
   handleContextMap.get(handle).setDriverStatus(DriverQueryStatus.DriverQueryState.CANCELED);
  }
  return cancelled;
 } catch (NullPointerException e) {
  throw new LensException("The query does not exist or was already purged", e);
 }
}

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

@Override
public boolean cancelQuery(QueryHandle handle) throws LensException {
 try {
  boolean cancelled = resultSetMap.get(handle).cancel(true);
  if (cancelled) {
   handleContextMap.get(handle).setDriverStatus(DriverQueryStatus.DriverQueryState.CANCELED);
  }
  return cancelled;
 } catch (NullPointerException e) {
  throw new LensException("The query does not exist or was already purged", e);
 }
}

代码示例来源：origin: org.apache.lens/lens-driver-jdbc

/**
 * Instantiates a new query callable.
 *
 * @param queryContext the query context
 */
public QueryCallable(JdbcQueryContext queryContext, @NonNull LogSegregationContext logSegregationContext) {
 this.queryContext = queryContext;
 this.logSegregationContext = logSegregationContext;
 queryContext.getLensContext().setDriverStatus(DriverQueryState.INITIALIZED);
}

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

/**
 * Instantiates a new query callable.
 *
 * @param queryContext the query context
 */
public QueryCallable(JdbcQueryContext queryContext, @NonNull LogSegregationContext logSegregationContext) {
 this.queryContext = queryContext;
 this.logSegregationContext = logSegregationContext;
 queryContext.getLensContext().setDriverStatus(DriverQueryState.INITIALIZED);
}

代码示例来源：origin: org.apache.lens/lens-driver-es

@Override
public LensResultSet execute(QueryContext context) throws LensException {
 handleContextMap.put(context.getQueryHandle(), context);
 final ESQuery esQuery = rewrite(context);
 final ESResultSet resultSet = esClient.execute(esQuery);
 context.setDriverStatus(DriverQueryStatus.DriverQueryState.SUCCESSFUL);
 handleContextMap.remove(context.getQueryHandle());
 return resultSet;
}

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

@Override
public LensResultSet execute(QueryContext context) throws LensException {
 handleContextMap.put(context.getQueryHandle(), context);
 final ESQuery esQuery = rewrite(context);
 final ESResultSet resultSet = esClient.execute(esQuery);
 context.setDriverStatus(DriverQueryStatus.DriverQueryState.SUCCESSFUL);
 handleContextMap.remove(context.getQueryHandle());
 return resultSet;
}

代码示例来源：origin: org.apache.lens/lens-driver-jdbc

/**
 * Cancel the execution of the query, specified by the handle.
 *
 * @param handle The query handle.
 * @return true if cancel was successful, false otherwise
 * @throws LensException the lens exception
 */
@Override
public boolean cancelQuery(QueryHandle handle) throws LensException {
 checkConfigured();
 JdbcQueryContext context = getQueryContext(handle);
 log.info("{} cancel request on query {}", getFullyQualifiedName(), handle);
 boolean cancelResult = context.cancel();
 if (cancelResult) {
  context.getLensContext().setDriverStatus(DriverQueryState.CANCELED);
  context.closeResult();
  log.info("{} Canceled query : {}", getFullyQualifiedName(), handle);
 }
 return cancelResult;
}

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

/**
 * Cancel the execution of the query, specified by the handle.
 *
 * @param handle The query handle.
 * @return true if cancel was successful, false otherwise
 * @throws LensException the lens exception
 */
@Override
public boolean cancelQuery(QueryHandle handle) throws LensException {
 checkConfigured();
 JdbcQueryContext context = getQueryContext(handle);
 log.info("{} cancel request on query {}", getFullyQualifiedName(), handle);
 boolean cancelResult = context.cancel();
 if (cancelResult) {
  context.getLensContext().setDriverStatus(DriverQueryState.CANCELED);
  context.closeResult();
  log.info("{} Canceled query : {}", getFullyQualifiedName(), handle);
 }
 return cancelResult;
}

代码示例来源：origin: org.apache.lens/lens-driver-jdbc

@Override
public QueryResult call() {
 logSegregationContext.setLogSegragationAndQueryId(this.queryContext.getQueryHandleString());
 queryContext.getLensContext().setDriverStatus(DriverQueryState.RUNNING);
 Statement stmt;
 Connection conn = null;
    queryContext.getLensContext().setDriverStatus(DriverQueryState.SUCCESSFUL);
   } catch (Exception e) {
    if (queryContext.getLensContext().getDriverStatus().isCanceled()) {
      e.getMessage(), e);
     result.error = e;
     queryContext.getLensContext().setDriverStatus(DriverQueryState.FAILED, e.getMessage());

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

@Override
public QueryResult call() {
 logSegregationContext.setLogSegragationAndQueryId(this.queryContext.getQueryHandleString());
 queryContext.getLensContext().setDriverStatus(DriverQueryState.RUNNING);
 Statement stmt;
 Connection conn = null;
    queryContext.getLensContext().setDriverStatus(DriverQueryState.SUCCESSFUL);
   } catch (Exception e) {
    if (queryContext.getLensContext().getDriverStatus().isCanceled()) {
      e.getMessage(), e);
     result.error = e;
     queryContext.getLensContext().setDriverStatus(DriverQueryState.FAILED, e.getMessage());