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

QueryContext.getUserQuery介绍

暂无

代码示例

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

@Override
 public String getLogHandle() {
  return super.getUserQuery();
 }
}

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

@Override
 public void preLaunch(QueryContext ctx) throws LensException {
  log.debug("Pre launch for user {}, user query: {}, driver {}, driver query: {}", ctx.getSubmittedUser(),
   ctx.getUserQuery(), ctx.getSelectedDriver().getFullyQualifiedName(), ctx.getSelectedDriverQuery());
 }
}

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

@Override
 public void preLaunch(QueryContext ctx) throws LensException {
  log.debug("Pre launch for user {}, user query: {}, driver {}, driver query: {}", ctx.getSubmittedUser(),
   ctx.getUserQuery(), ctx.getSelectedDriver().getFullyQualifiedName(), ctx.getSelectedDriverQuery());
 }
}

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

@Override
public void executeAsync(final QueryContext ctx) throws LensException {
 // simulate wait for execution.
 if (ctx.getUserQuery().contains("wait")) {
  try {
   // wait for 1 second.
   Thread.sleep(1000);
  } catch (InterruptedException e) {
   // ignore interrupted exception
  }
 }
 // simulate autocancel.
 if (ctx.getUserQuery().contains("autocancel")) {
  return;
 }
 throw new LensException("Simulated Launch Failure");
}

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

/**
 * Returns the query handle if the same query is already launched by the user
 * in the same session.
 *
 * @param query
 * @param sessionHandle
 * @param conf
 * @param queryName
 * @return
 */
private QueryHandle checkForDuplicateQuery(String query, LensSessionHandle sessionHandle, Configuration conf,
  String queryName) {
 // Get all active queries of this session.
 List<QueryHandle> activeQueries = getSession(sessionHandle).getActiveQueries();
 synchronized (activeQueries) {
  for (QueryHandle handle : activeQueries) {
   QueryContext context = allQueries.get(handle);
   if (queryName.equals(context.getQueryName()) && query.equals(context.getUserQuery())
     && Arrays.equals(UtilityMethods.generateHashOfWritable(conf), context.getQueryConfHash())) {
    return handle;
   }
  }
 }
 return null;
}

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

DriverSelectorQueryContext driverCtx = new DriverSelectorQueryContext(ctx.getUserQuery(), new Configuration(),
 drivers.values());
ctx.setDriverContext(driverCtx);

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

log.info("Processing query:{}", query.getUserQuery());

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

/**
 * Test insert overwrite conf.
 *
 * @throws Exception the exception
 */
@Test
public void testInsertOverwriteConf() throws Exception {
 createTestTable("test_insert_overwrite");
 queryConf.setBoolean(LensConfConstants.QUERY_ADD_INSERT_OVEWRITE, false);
 String query = "SELECT ID FROM test_insert_overwrite";
 QueryContext context = createContext(query, queryConf);
 driver.addPersistentPath(context);
 assertEquals(context.getUserQuery(), query);
 assertNotNull(context.getDriverContext().getDriverQuery(driver));
 assertEquals(context.getDriverContext().getDriverQuery(driver), context.getUserQuery());
}

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

OperationStatus status = getClient().getOperationStatus(op);
if (status.getState() == OperationState.ERROR) {
 throw new LensException("Unknown error while running query " + ctx.getUserQuery());

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

@Override
public void updateStatus(QueryContext context) throws LensException {
 updateCount++;
 if ("simulate status retries".equals(context.getUserQuery())) {
  try {
   if (updateCount < 3) {
 if ("simulate status failure".equals(context.getUserQuery())) {
  try {
   throw new SocketTimeoutException("simulated timeout exception");
 if (context.getUserQuery().contains("autocancel")) {
  if (!cancel) {
   context.getDriverStatus().setState(DriverQueryState.RUNNING);

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

OperationStatus status = getClient().getOperationStatus(op);
if (status.getState() == OperationState.ERROR) {
 throw new LensException("Unknown error while running query " + ctx.getUserQuery());

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

event.setCause(ended.getCause() != null ? ended.getCause() : "");
event.setResult(ctx.getResultSetPath());
event.setUserQuery(ctx.getUserQuery());
event.setSessionId(ctx.getLensSessionIdentifier());
event.setHandle(ctx.getQueryHandle().toString());

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

assertEquals(ctx.getPhase1RewrittenQuery(), ctx.getUserQuery()); //Since there is no rewriter in this test
assertEquals(lensQuery.getStatus().getStatus(), QueryStatus.Status.SUCCESSFUL);

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

this.userQuery = ctx.getUserQuery();
this.submitter = ctx.getSubmittedUser();
this.submissionTime = ctx.getSubmissionTime();

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

this.userQuery = ctx.getUserQuery();
this.submitter = ctx.getSubmittedUser();
this.submissionTime = ctx.getSubmissionTime();