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

QueryContext.getSelectedDriverQuery介绍

暂无

代码示例

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

@Override
public void executeAsync(QueryContext context) throws LensException {
 cancel = false;
 this.query = context.getSelectedDriverQuery();
}

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

@Override
public LensResultSet execute(QueryContext context) throws LensException {
 this.query = context.getSelectedDriverQuery();
 return new PersistentResultSet() {

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

LensConfConstants.QUERY_ADD_INSERT_OVEWRITE, LensConfConstants.DEFAULT_ADD_INSERT_OVEWRITE);
if (context.isDriverPersistent() && addInsertOverwrite
 && (context.getSelectedDriverQuery().startsWith("SELECT")
 || context.getSelectedDriverQuery().startsWith("select"))) {
  builder.append(outputDirFormat);
 builder.append(' ').append(context.getSelectedDriverQuery()).append(' ');
 hiveQuery = builder.toString();
} else {
 context.unSetDriverPersistent();
 hiveQuery = context.getSelectedDriverQuery();

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

LensConfConstants.QUERY_ADD_INSERT_OVEWRITE, LensConfConstants.DEFAULT_ADD_INSERT_OVEWRITE);
if (context.isDriverPersistent() && addInsertOverwrite
 && (context.getSelectedDriverQuery().startsWith("SELECT")
 || context.getSelectedDriverQuery().startsWith("select"))) {
  builder.append(outputDirFormat);
 builder.append(' ').append(context.getSelectedDriverQuery()).append(' ');
 hiveQuery = builder.toString();
} else {
 context.unSetDriverPersistent();
 hiveQuery = context.getSelectedDriverQuery();

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

if (drivers.get(selectedDriverQualifiedName) != null) {
 ctx.getDriverContext().setSelectedDriver(drivers.get(selectedDriverQualifiedName));
 ctx.setDriverQuery(ctx.getSelectedDriver(), ctx.getSelectedDriverQuery());
} else {
 log.info("Ignoring {} as the driver is not loaded", ctx.getQueryHandle());

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

@Override
public void executeAsync(QueryContext ctx) throws LensException {
 try {
  addPersistentPath(ctx);
  Configuration qdconf = ctx.getDriverConf(this);
  qdconf.set("mapred.job.name", ctx.getQueryHandle().toString());
  decidePriority(ctx);
  SessionHandle sessionHandle = getSession(ctx);
  OperationHandle op = getClient().executeStatementAsync(sessionHandle, ctx.getSelectedDriverQuery(),
   qdconf.getValByRegex(".*"));
  ctx.setDriverOpHandle(op.toString());
  log.info("QueryHandle: {} HiveHandle:{}", ctx.getQueryHandle(), op);
  hiveHandles.put(ctx.getQueryHandle(), op);
  opHandleToSession.put(op, sessionHandle);
 } catch (IOException e) {
  throw new LensException("Error adding persistent path", e);
 } catch (HiveSQLException e) {
  handleHiveServerError(ctx, e);
  handleHiveSQLException(e);
 }
}

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

@Override
public void executeAsync(QueryContext ctx) throws LensException {
 try {
  addPersistentPath(ctx);
  Configuration qdconf = ctx.getDriverConf(this);
  qdconf.set("mapred.job.name", ctx.getQueryHandle().toString());
  decidePriority(ctx);
  SessionHandle sessionHandle = getSession(ctx);
  OperationHandle op = getClient().executeStatementAsync(sessionHandle, ctx.getSelectedDriverQuery(),
   qdconf.getValByRegex(".*"));
  ctx.setDriverOpHandle(op.toString());
  log.info("QueryHandle: {} HiveHandle:{}", ctx.getQueryHandle(), op);
  hiveHandles.put(ctx.getQueryHandle(), op);
  opHandleToSession.put(op, sessionHandle);
 } catch (IOException e) {
  throw new LensException("Error adding persistent path", e);
 } catch (HiveSQLException e) {
  handleHiveServerError(ctx, e);
  handleHiveSQLException(e);
 }
}

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

/**
 * To lens query.
 *
 * @return the lens query
 */
public LensQuery toLensQuery() {
 return new LensQuery(queryHandle, userQuery, super.getSubmittedUser(), getPriority(), isPersistent,
  getSelectedDriver() != null ? getSelectedDriver().getFullyQualifiedName() : null,
  getSelectedDriverQuery(),
  status,
  resultSetPath, driverOpHandle, lensConf, submissionTime, launchTime, driverStatus.getDriverStartTime(),
  driverStatus.getDriverFinishTime(), endTime, closedTime, queryName, getFailedAttempts());
}

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

/**
 * To lens query.
 *
 * @return the lens query
 */
public LensQuery toLensQuery() {
 return new LensQuery(queryHandle, userQuery, super.getSubmittedUser(), getPriority(), isPersistent,
  getSelectedDriver() != null ? getSelectedDriver().getFullyQualifiedName() : null,
  getSelectedDriverQuery(),
  status,
  resultSetPath, driverOpHandle, lensConf, submissionTime, launchTime, driverStatus.getDriverStartTime(),
  driverStatus.getDriverFinishTime(), endTime, closedTime, queryName, getFailedAttempts());
}

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

qdconf.set("mapred.job.name", ctx.getQueryHandle().toString());
SessionHandle sessionHandle = getSession(ctx);
op = getClient().executeStatement(sessionHandle, ctx.getSelectedDriverQuery(), qdconf.getValByRegex(".*"));
log.info("The hive operation handle: {}", op);
ctx.setDriverOpHandle(op.toString());

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

qdconf.set("mapred.job.name", ctx.getQueryHandle().toString());
SessionHandle sessionHandle = getSession(ctx);
op = getClient().executeStatement(sessionHandle, ctx.getSelectedDriverQuery(), qdconf.getValByRegex(".*"));
log.info("The hive operation handle: {}", op);
ctx.setDriverOpHandle(op.toString());

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

event.setSubmissionTime(ctx.getSubmissionTime());
QueryDriverStatistics driverStats = new QueryDriverStatistics();
driverStats.setDriverQuery(ctx.getSelectedDriverQuery());
driverStats.setStartTime(ctx.getDriverStatus().getDriverStartTime());
driverStats.setEndTime(ctx.getDriverStatus().getDriverFinishTime());

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

Assert.assertEquals(retrievedQueryContext.getSelectedDriverQuery(), driverQuery);

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

if (null != ctx.getSelectedDriver()) {
 this.driverName = ctx.getSelectedDriver().getFullyQualifiedName();
 this.driverQuery = ctx.getSelectedDriverQuery();

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

if (null != ctx.getSelectedDriver()) {
 this.driverName = ctx.getSelectedDriver().getFullyQualifiedName();
 this.driverQuery = ctx.getSelectedDriverQuery();