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

QueryContext.getDriverConf介绍

暂无

代码示例

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

Configuration qdconf = context.getDriverConf(this);
boolean addInsertOverwrite = qdconf.getBoolean(
 LensConfConstants.QUERY_ADD_INSERT_OVEWRITE, LensConfConstants.DEFAULT_ADD_INSERT_OVEWRITE);

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

Configuration qdconf = context.getDriverConf(this);
boolean addInsertOverwrite = qdconf.getBoolean(
 LensConfConstants.QUERY_ADD_INSERT_OVEWRITE, LensConfConstants.DEFAULT_ADD_INSERT_OVEWRITE);

代码示例来源：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: 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: apache/lens

try {
 addPersistentPath(ctx);
 Configuration qdconf = ctx.getDriverConf(this);
 qdconf.set("mapred.job.name", ctx.getQueryHandle().toString());
 SessionHandle sessionHandle = getSession(ctx);

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

assertTrue(ctx.isDriverQueryExplicitlySet());
for (LensDriver driver : queryService.getDrivers()) {
 Configuration dconf = ctx.getDriverConf(driver);
 assertEquals(dconf.get("test.session.key"), "svalue");

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

try {
 addPersistentPath(ctx);
 Configuration qdconf = ctx.getDriverConf(this);
 qdconf.set("mapred.job.name", ctx.getQueryHandle().toString());
 SessionHandle sessionHandle = getSession(ctx);

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

QueryContext context = createContext(select, queryConf);
resultSet = driver.execute(context);
assertNotNull(context.getDriverConf(driver).get("mapred.job.name"));
validateInMemoryResult(resultSet);
queryConf.setBoolean(LensConfConstants.QUERY_PERSISTENT_RESULT_INDRIVER, true);

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

context = createContext(select, queryConf);
driver.executeAsync(context);
assertNotNull(context.getDriverConf(driver).get("mapred.job.name"));
assertNotNull(context.getDriverConf(driver).get("mapred.job.priority"));
assertHandleSize(handleSize + 1);
validateExecuteAsync(context, DriverQueryState.SUCCESSFUL, false, false);