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

QueryContext.setSelectedDriver介绍

暂无

代码示例

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

/**
 * Instantiates a new query context.
 *
 * @param userQuery      the user query
 * @param user           the user
 * @param qconf          the qconf
 * @param conf           the conf
 * @param drivers        All the drivers
 * @param selectedDriver the selected driver
 * @param submissionTime the submission time
 */
QueryContext(String userQuery, String user, LensConf qconf, Configuration conf, Collection<LensDriver> drivers,
 LensDriver selectedDriver, long submissionTime, boolean mergeDriverConf) {
 super(userQuery, user, qconf, conf, drivers, mergeDriverConf);
 this.submissionTime = submissionTime;
 this.queryHandle = new QueryHandle(UUID.randomUUID());
 this.status = new QueryStatus(0.0f, null, Status.NEW, "Query just got created", false, null, null, null);
 this.lensConf = qconf;
 this.conf = conf;
 this.isPersistent = conf.getBoolean(LensConfConstants.QUERY_PERSISTENT_RESULT_SET,
  LensConfConstants.DEFAULT_PERSISTENT_RESULT_SET);
 this.isDriverPersistent = conf.getBoolean(LensConfConstants.QUERY_PERSISTENT_RESULT_INDRIVER,
  LensConfConstants.DEFAULT_DRIVER_PERSISTENT_RESULT_SET);
 this.userQuery = userQuery;
 if (selectedDriver != null) {
  this.setSelectedDriver(selectedDriver);
 }
 this.lensConf = qconf;
 this.driverStatus = new DriverQueryStatus();
}

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

/**
 * Instantiates a new query context.
 *
 * @param userQuery      the user query
 * @param user           the user
 * @param qconf          the qconf
 * @param conf           the conf
 * @param drivers        All the drivers
 * @param selectedDriver the selected driver
 * @param submissionTime the submission time
 */
QueryContext(String userQuery, String user, LensConf qconf, Configuration conf, Collection<LensDriver> drivers,
 LensDriver selectedDriver, long submissionTime, boolean mergeDriverConf) {
 super(userQuery, user, qconf, conf, drivers, mergeDriverConf);
 this.submissionTime = submissionTime;
 this.queryHandle = new QueryHandle(UUID.randomUUID());
 this.status = new QueryStatus(0.0f, null, Status.NEW, "Query just got created", false, null, null, null);
 this.lensConf = qconf;
 this.conf = conf;
 this.isPersistent = conf.getBoolean(LensConfConstants.QUERY_PERSISTENT_RESULT_SET,
  LensConfConstants.DEFAULT_PERSISTENT_RESULT_SET);
 this.isDriverPersistent = conf.getBoolean(LensConfConstants.QUERY_PERSISTENT_RESULT_INDRIVER,
  LensConfConstants.DEFAULT_DRIVER_PERSISTENT_RESULT_SET);
 this.userQuery = userQuery;
 if (selectedDriver != null) {
  this.setSelectedDriver(selectedDriver);
 }
 this.driverStatus = new DriverQueryStatus();
}

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

/**
 * Read context.
 *
 * @param bytes  the bytes
 * @param driver the driver
 * @return the query context
 * @throws IOException            Signals that an I/O exception has occurred.
 * @throws ClassNotFoundException the class not found exception
 */
private QueryContext readContext(byte[] bytes, LensDriver driver) throws IOException,
 ClassNotFoundException {
 ByteArrayInputStream bais = new ByteArrayInputStream(bytes);
 ObjectInputStream in = new ObjectInputStream(bais);
 QueryContext ctx;
 try {
  ctx = (QueryContext) in.readObject();
  ctx.setConf(queryConf);
  boolean driverAvailable = in.readBoolean();
  if (driverAvailable) {
   String driverQualifiedName = in.readUTF();
   ctx.setSelectedDriver(driver);
  }
 } finally {
  in.close();
  bais.close();
 }
 return ctx;
}

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