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

QueryContext.setQueryName介绍

暂无

代码示例

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

@Override
public QueryHandleWithResultSet executePrepare(LensSessionHandle sessionHandle, QueryPrepareHandle prepareHandle,
 long timeoutMillis, LensConf conf, String queryName) throws LensException {
 try {
  log.info("ExecutePrepare: session:{} prepareHandle: {} timeout:{}", sessionHandle,
   prepareHandle.getPrepareHandleId(), timeoutMillis);
  acquire(sessionHandle);
  PreparedQueryContext pctx = getPreparedQueryContext(sessionHandle, prepareHandle);
  Configuration qconf = getLensConf(sessionHandle, conf);
  QueryContext ctx = createContext(pctx, getSession(sessionHandle).getLoggedInUser(), conf, qconf, timeoutMillis);
  if (StringUtils.isNotBlank(queryName)) {
   // Override previously set query name
   ctx.setQueryName(queryName);
  } else {
   ctx.setQueryName(pctx.getQueryName());
  }
  return executeTimeoutInternal(sessionHandle, ctx, timeoutMillis, qconf);
 } finally {
  release(sessionHandle);
 }
}

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

@Override
public QueryHandle executePrepareAsync(LensSessionHandle sessionHandle, QueryPrepareHandle prepareHandle,
 LensConf conf, String queryName) throws LensException {
 try {
  log.info("ExecutePrepareAsync: session:{} prepareHandle:{}", sessionHandle, prepareHandle.getPrepareHandleId());
  acquire(sessionHandle);
  PreparedQueryContext pctx = getPreparedQueryContext(sessionHandle, prepareHandle);
  Configuration qconf = getLensConf(sessionHandle, conf);
  accept(pctx.getUserQuery(), qconf, SubmitOp.EXECUTE);
  QueryContext ctx = createContext(pctx, getSession(sessionHandle).getLoggedInUser(), conf, qconf, 0);
  if (StringUtils.isNotBlank(queryName)) {
   // Override previously set query name
   ctx.setQueryName(queryName);
  } else {
   ctx.setQueryName(pctx.getQueryName());
  }
  ctx.setLensSessionIdentifier(sessionHandle.getPublicId().toString());
  return submitQuery(ctx);
 } finally {
  release(sessionHandle);
 }
}

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

@Override
public QueryHandleWithResultSet execute(LensSessionHandle sessionHandle, String query, long timeoutMillis,
 LensConf conf, String queryName) throws LensException {
 try {
  log.info("Blocking execute session:{} query: {} timeout: {}", sessionHandle, query, timeoutMillis);
  acquire(sessionHandle);
  Configuration qconf = getLensConf(sessionHandle, conf);
  accept(query, qconf, SubmitOp.EXECUTE);
  QueryContext ctx = createContext(query, getSession(sessionHandle).getLoggedInUser(), conf, qconf, timeoutMillis);
  ctx.setQueryName(queryName);
  ctx.setLensSessionIdentifier(sessionHandle.getPublicId().toString());
  rewriteAndSelect(ctx);
  return executeTimeoutInternal(sessionHandle, ctx, timeoutMillis, qconf);
 } finally {
  release(sessionHandle);
 }
}

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

@Override
public QueryHandle executeAsync(LensSessionHandle sessionHandle, String query, LensConf conf, String queryName)
 throws LensException {
 try {
  log.info("ExecuteAsync: session:{} query: {}", sessionHandle, query);
  acquire(sessionHandle);
  Configuration qconf = getLensConf(sessionHandle, conf);
  accept(query, qconf, SubmitOp.EXECUTE);
  if (!isDuplicateQueryAllowed) {
   QueryHandle previousHandle = checkForDuplicateQuery(query, sessionHandle, qconf, queryName);
   if (previousHandle != null) {
    log.info("Query:{} Session:{} User:{} duplicate query found", query, sessionHandle, getSession(sessionHandle)
      .getLoggedInUser());
    return previousHandle;
   }
  }
  QueryContext ctx = createContext(query, getSession(sessionHandle).getLoggedInUser(), conf, qconf, 0);
  // Should be set only once
  ctx.setQueryConfHash(UtilityMethods.generateHashOfWritable(qconf));
  ctx.setQueryName(queryName);
  try {
   lensServerDao.insertActiveQuery(ctx);
  } catch (Exception e) {
   incrCounter(ACTIVE_QUERY_INSERT_ERROR_COUNTER);
  }
  return executeAsyncInternal(sessionHandle, ctx);
 } finally {
  release(sessionHandle);
 }
}

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

/**
 * Creates the query context
 * @param conf      the conf
 * @param queryName the name of query
 * @return the query context
 */
protected QueryContext createContext(Configuration conf, String queryName) {
 final LensDriver mockDriver = new MockDriver();
 try {
  mockDriver.configure(conf, null, null);
 } catch (LensException e) {
  Assert.fail(e.getMessage());
 }
 QueryContext ctx = QueryContext.createContextWithSingleDriver("test writer query", "testuser",
  new LensConf(), conf, mockDriver, null, false);
 ctx.setSelectedDriver(mockDriver);
 ctx.setQueryName(queryName);
 return ctx;
}

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

new Configuration(), 0);
long submissionTime = queryContext.getSubmissionTime();
queryContext.setQueryName("daoTestQuery1");
queryContext.getDriverContext().setSelectedDriver(new MockDriver());
queryContext.getLensConf().addProperty("prop", "value");

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